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
- UpdateCommand.cs
- ThreadStartException.cs
- FormatSettings.cs
- LayoutTableCell.cs
- SettingsAttributes.cs
- Ipv6Element.cs
- ToolStripItemRenderEventArgs.cs
- BamlBinaryReader.cs
- APCustomTypeDescriptor.cs
- ContainerControl.cs
- ProfilePropertySettingsCollection.cs
- LocalFileSettingsProvider.cs
- SwitchLevelAttribute.cs
- JumpList.cs
- BuildProviderCollection.cs
- XmlJsonWriter.cs
- GroupBoxRenderer.cs
- ParserStreamGeometryContext.cs
- TableLayoutStyleCollection.cs
- Int16AnimationBase.cs
- CompositeActivityTypeDescriptorProvider.cs
- UpdatePanelTriggerCollection.cs
- EpmTargetPathSegment.cs
- Transactions.cs
- AuthenticationModuleElementCollection.cs
- ConstraintConverter.cs
- XmlAttributeAttribute.cs
- TargetPerspective.cs
- DataGridViewCellCancelEventArgs.cs
- AutomationIdentifierGuids.cs
- XDRSchema.cs
- KerberosReceiverSecurityToken.cs
- XmlSchemaSequence.cs
- XmlSchemaSimpleTypeUnion.cs
- ConnectionInterfaceCollection.cs
- StrongNameIdentityPermission.cs
- TabControl.cs
- BamlLocalizableResourceKey.cs
- ExpressionLexer.cs
- DSASignatureFormatter.cs
- ObfuscationAttribute.cs
- NativeCompoundFileAPIs.cs
- ReadOnlyDictionary.cs
- InvalidTimeZoneException.cs
- DataGridColumn.cs
- SyndicationLink.cs
- CodeDelegateCreateExpression.cs
- FormClosingEvent.cs
- ComponentChangingEvent.cs
- CodeTypeReference.cs
- DefaultObjectMappingItemCollection.cs
- GraphicsContainer.cs
- ParserExtension.cs
- Timer.cs
- VerticalAlignConverter.cs
- ThreadStateException.cs
- _DisconnectOverlappedAsyncResult.cs
- BaseValidator.cs
- PerformanceCounterLib.cs
- SystemResourceKey.cs
- RenderDataDrawingContext.cs
- CodeTypeDeclaration.cs
- FlowchartStart.xaml.cs
- FixedHighlight.cs
- ProtocolElementCollection.cs
- _SslStream.cs
- RootProfilePropertySettingsCollection.cs
- MulticastNotSupportedException.cs
- WebBrowserPermission.cs
- ComEventsSink.cs
- CodeTypeParameter.cs
- DateTimePicker.cs
- SimpleWorkerRequest.cs
- DispatchChannelSink.cs
- AssemblyResolver.cs
- RowToFieldTransformer.cs
- TextReader.cs
- Membership.cs
- Visual3D.cs
- SplitContainerDesigner.cs
- TagMapCollection.cs
- SingleResultAttribute.cs
- ContractMethodParameterInfo.cs
- PixelFormats.cs
- TextCompositionEventArgs.cs
- MarginsConverter.cs
- Quaternion.cs
- DocumentPageView.cs
- AppSettingsExpressionBuilder.cs
- WpfKnownMember.cs
- PeerObject.cs
- OciEnlistContext.cs
- XamlSerializationHelper.cs
- XmlUrlResolver.cs
- DBCommand.cs
- SqlCacheDependencyDatabase.cs
- TextTreeTextNode.cs
- DbFunctionCommandTree.cs
- OletxCommittableTransaction.cs