Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Services / Web / System / Web / Services / Protocols / SoapExtensionStream.cs / 1305376 / SoapExtensionStream.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web.Services.Protocols { using System; using System.IO; using System.Web.Services; internal class SoapExtensionStream : Stream { internal Stream innerStream; bool hasWritten = false; bool streamReady; internal SoapExtensionStream() { } private bool EnsureStreamReady() { if (streamReady) return true; throw new InvalidOperationException(Res.GetString(Res.WebBadStreamState)); } public override bool CanRead { get { EnsureStreamReady(); return innerStream.CanRead; } } public override bool CanSeek { get { EnsureStreamReady(); return innerStream.CanSeek; } } public override bool CanWrite { get { EnsureStreamReady(); return innerStream.CanWrite; } } internal bool HasWritten { get { return this.hasWritten; } } public override long Length { get { EnsureStreamReady(); return innerStream.Length; } } public override long Position { get { EnsureStreamReady(); return innerStream.Position; } set { EnsureStreamReady(); this.hasWritten = true; innerStream.Position = value; } } protected override void Dispose(bool disposing) { try { if (disposing) { EnsureStreamReady(); this.hasWritten = true; innerStream.Close(); } } finally { base.Dispose(disposing); } } public override void Flush() { EnsureStreamReady(); this.hasWritten = true; innerStream.Flush(); } public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, Object state) { EnsureStreamReady(); return innerStream.BeginRead(buffer, offset, count, callback, state); } public override int EndRead(IAsyncResult asyncResult) { EnsureStreamReady(); return innerStream.EndRead(asyncResult); } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, Object state) { EnsureStreamReady(); this.hasWritten = true; return innerStream.BeginWrite(buffer, offset, count, callback, state); } public override void EndWrite(IAsyncResult asyncResult) { EnsureStreamReady(); this.hasWritten = true; innerStream.EndWrite(asyncResult); } public override long Seek(long offset, SeekOrigin origin) { EnsureStreamReady(); return innerStream.Seek(offset, origin); } public override void SetLength(long value) { EnsureStreamReady(); innerStream.SetLength(value); } public override int Read(byte[] buffer, int offset, int count) { EnsureStreamReady(); return innerStream.Read(buffer, offset, count); } public override int ReadByte() { EnsureStreamReady(); return innerStream.ReadByte(); } public override void Write(byte[] buffer, int offset, int count) { EnsureStreamReady(); this.hasWritten = true; innerStream.Write(buffer, offset, count); } public override void WriteByte(byte value) { EnsureStreamReady(); this.hasWritten = true; innerStream.WriteByte(value); } internal void SetInnerStream(Stream stream) { innerStream = stream; this.hasWritten = false; } internal void SetStreamReady() { streamReady = true; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web.Services.Protocols { using System; using System.IO; using System.Web.Services; internal class SoapExtensionStream : Stream { internal Stream innerStream; bool hasWritten = false; bool streamReady; internal SoapExtensionStream() { } private bool EnsureStreamReady() { if (streamReady) return true; throw new InvalidOperationException(Res.GetString(Res.WebBadStreamState)); } public override bool CanRead { get { EnsureStreamReady(); return innerStream.CanRead; } } public override bool CanSeek { get { EnsureStreamReady(); return innerStream.CanSeek; } } public override bool CanWrite { get { EnsureStreamReady(); return innerStream.CanWrite; } } internal bool HasWritten { get { return this.hasWritten; } } public override long Length { get { EnsureStreamReady(); return innerStream.Length; } } public override long Position { get { EnsureStreamReady(); return innerStream.Position; } set { EnsureStreamReady(); this.hasWritten = true; innerStream.Position = value; } } protected override void Dispose(bool disposing) { try { if (disposing) { EnsureStreamReady(); this.hasWritten = true; innerStream.Close(); } } finally { base.Dispose(disposing); } } public override void Flush() { EnsureStreamReady(); this.hasWritten = true; innerStream.Flush(); } public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, Object state) { EnsureStreamReady(); return innerStream.BeginRead(buffer, offset, count, callback, state); } public override int EndRead(IAsyncResult asyncResult) { EnsureStreamReady(); return innerStream.EndRead(asyncResult); } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, Object state) { EnsureStreamReady(); this.hasWritten = true; return innerStream.BeginWrite(buffer, offset, count, callback, state); } public override void EndWrite(IAsyncResult asyncResult) { EnsureStreamReady(); this.hasWritten = true; innerStream.EndWrite(asyncResult); } public override long Seek(long offset, SeekOrigin origin) { EnsureStreamReady(); return innerStream.Seek(offset, origin); } public override void SetLength(long value) { EnsureStreamReady(); innerStream.SetLength(value); } public override int Read(byte[] buffer, int offset, int count) { EnsureStreamReady(); return innerStream.Read(buffer, offset, count); } public override int ReadByte() { EnsureStreamReady(); return innerStream.ReadByte(); } public override void Write(byte[] buffer, int offset, int count) { EnsureStreamReady(); this.hasWritten = true; innerStream.Write(buffer, offset, count); } public override void WriteByte(byte value) { EnsureStreamReady(); this.hasWritten = true; innerStream.WriteByte(value); } internal void SetInnerStream(Stream stream) { innerStream = stream; this.hasWritten = false; } internal void SetStreamReady() { streamReady = true; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ToolStripArrowRenderEventArgs.cs
- HWStack.cs
- FunctionUpdateCommand.cs
- AttributeProviderAttribute.cs
- PtsContext.cs
- SchemaElementLookUpTable.cs
- DataGridLinkButton.cs
- BinaryReader.cs
- FrameSecurityDescriptor.cs
- SafeCryptHandles.cs
- FormatVersion.cs
- TableRowGroupCollection.cs
- Point3DCollectionConverter.cs
- RadioButton.cs
- COM2ExtendedBrowsingHandler.cs
- SystemWebExtensionsSectionGroup.cs
- DateTimeOffsetAdapter.cs
- ThumbButtonInfo.cs
- RuleInfoComparer.cs
- BuildManagerHost.cs
- ResizeGrip.cs
- WebPartConnectionsCancelEventArgs.cs
- ControlFilterExpression.cs
- BooleanToVisibilityConverter.cs
- EntityDataSourceSelectedEventArgs.cs
- DynamicMethod.cs
- Speller.cs
- ContainerActivationHelper.cs
- StructuralCache.cs
- CheckBoxList.cs
- BuildManagerHost.cs
- EncodingDataItem.cs
- Section.cs
- ColumnMap.cs
- DbReferenceCollection.cs
- OdbcDataReader.cs
- infer.cs
- UniqueCodeIdentifierScope.cs
- HideDisabledControlAdapter.cs
- TextBoxRenderer.cs
- OutOfMemoryException.cs
- RtfNavigator.cs
- SelectedPathEditor.cs
- TextRangeEditLists.cs
- UnionCodeGroup.cs
- WindowsListViewItemCheckBox.cs
- SystemEvents.cs
- DataGridViewAutoSizeColumnsModeEventArgs.cs
- DragStartedEventArgs.cs
- CqlBlock.cs
- PasswordRecovery.cs
- MimePart.cs
- TraceContextRecord.cs
- Debugger.cs
- Misc.cs
- keycontainerpermission.cs
- RichTextBoxAutomationPeer.cs
- ObjectConverter.cs
- SizeAnimationClockResource.cs
- GeneralTransform3DCollection.cs
- MemoryRecordBuffer.cs
- Decoder.cs
- QueryableFilterUserControl.cs
- DateTimeConverter2.cs
- ErrorProvider.cs
- Encoder.cs
- ControlParameter.cs
- DockPattern.cs
- PointHitTestResult.cs
- FileFormatException.cs
- SizeValueSerializer.cs
- DataContractSerializerOperationGenerator.cs
- LinqDataSourceHelper.cs
- StreamGeometry.cs
- DropShadowBitmapEffect.cs
- AlgoModule.cs
- ExceptionValidationRule.cs
- ScriptingProfileServiceSection.cs
- XmlQueryOutput.cs
- RawKeyboardInputReport.cs
- PtsPage.cs
- SmiRequestExecutor.cs
- AssemblyBuilder.cs
- NameGenerator.cs
- EditorZone.cs
- ContentPathSegment.cs
- DataSvcMapFileSerializer.cs
- SymLanguageType.cs
- HttpProcessUtility.cs
- ScriptControlDescriptor.cs
- UndoEngine.cs
- BufferAllocator.cs
- FixedPosition.cs
- UMPAttributes.cs
- XmlElementCollection.cs
- SafeFileMappingHandle.cs
- TextHidden.cs
- PlatformCulture.cs
- MemoryMappedFileSecurity.cs
- MimeXmlReflector.cs