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
- WebPartPersonalization.cs
- LineInfo.cs
- COM2PictureConverter.cs
- ContainerSelectorActiveEvent.cs
- XmlSchemaSimpleContentExtension.cs
- NonVisualControlAttribute.cs
- ReaderWriterLock.cs
- BufferedWebEventProvider.cs
- _emptywebproxy.cs
- DrawingContextDrawingContextWalker.cs
- XmlValueConverter.cs
- DataKeyArray.cs
- baseaxisquery.cs
- TextTreeInsertElementUndoUnit.cs
- PropVariant.cs
- ControlAdapter.cs
- TextTreeRootTextBlock.cs
- Assembly.cs
- TextRangeEditTables.cs
- RequestContext.cs
- GridSplitter.cs
- Point.cs
- ClientOptions.cs
- COM2ExtendedTypeConverter.cs
- CustomErrorsSectionWrapper.cs
- AutoScrollExpandMessageFilter.cs
- SynchronizingStream.cs
- MetadataException.cs
- ExtendedProtectionPolicy.cs
- SqlDataSourceCache.cs
- DesignTimeTemplateParser.cs
- FullTextState.cs
- WeakReference.cs
- SimpleType.cs
- IdentityHolder.cs
- DependencyPropertyValueSerializer.cs
- sortedlist.cs
- TargetPerspective.cs
- UxThemeWrapper.cs
- WebAdminConfigurationHelper.cs
- TagMapCollection.cs
- HandoffBehavior.cs
- MarkupCompiler.cs
- ResXResourceWriter.cs
- Decimal.cs
- HebrewNumber.cs
- CacheOutputQuery.cs
- BitmapEffectrendercontext.cs
- SpellerInterop.cs
- TableLayoutSettings.cs
- LogEntry.cs
- Geometry3D.cs
- ClientSideQueueItem.cs
- XmlChoiceIdentifierAttribute.cs
- StructureChangedEventArgs.cs
- Attributes.cs
- HtmlInputRadioButton.cs
- TreeNodeSelectionProcessor.cs
- DataColumnCollection.cs
- PriorityQueue.cs
- ADMembershipUser.cs
- CryptoStream.cs
- ErrorRuntimeConfig.cs
- SQLBoolean.cs
- ChannelDispatcherBase.cs
- XPathParser.cs
- clipboard.cs
- DataFormats.cs
- SizeAnimationClockResource.cs
- SafeMemoryMappedFileHandle.cs
- WebConfigManager.cs
- SymbolUsageManager.cs
- ImageFormatConverter.cs
- OdbcUtils.cs
- mediaeventargs.cs
- TransportChannelFactory.cs
- ChineseLunisolarCalendar.cs
- ToolStripStatusLabel.cs
- AssemblyInfo.cs
- DataView.cs
- InvokeGenerator.cs
- SqlTypesSchemaImporter.cs
- Set.cs
- SslStream.cs
- HelpInfo.cs
- Help.cs
- Rect3DValueSerializer.cs
- ECDsaCng.cs
- FragmentQuery.cs
- ExceptionHelpers.cs
- Int32AnimationBase.cs
- Rules.cs
- RepeaterDataBoundAdapter.cs
- BoundingRectTracker.cs
- RegexCompiler.cs
- FrameworkElement.cs
- DefaultBinder.cs
- DynamicUpdateCommand.cs
- ImageAttributes.cs
- LocatorGroup.cs