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
- pingexception.cs
- SafeLibraryHandle.cs
- ComplusTypeValidator.cs
- StoreItemCollection.cs
- AbandonedMutexException.cs
- KeyValueConfigurationCollection.cs
- FormatterServices.cs
- QueryContinueDragEventArgs.cs
- ResXDataNode.cs
- OrderedDictionaryStateHelper.cs
- ServicePoint.cs
- WebServiceResponse.cs
- WebBrowserProgressChangedEventHandler.cs
- DataGridViewRowsAddedEventArgs.cs
- SchemaComplexType.cs
- ResourceDisplayNameAttribute.cs
- ParserOptions.cs
- NotFiniteNumberException.cs
- Stack.cs
- LinkClickEvent.cs
- RowUpdatingEventArgs.cs
- Verify.cs
- SmiRecordBuffer.cs
- RelatedCurrencyManager.cs
- NotifyIcon.cs
- AnnotationComponentManager.cs
- Window.cs
- IFormattable.cs
- ImageCodecInfo.cs
- CodeSnippetCompileUnit.cs
- Memoizer.cs
- DBBindings.cs
- Substitution.cs
- dataprotectionpermission.cs
- DrawingContextWalker.cs
- QilInvokeEarlyBound.cs
- BitmapEffectInputConnector.cs
- CounterNameConverter.cs
- ActivityExecutionContextCollection.cs
- CollectionBuilder.cs
- IProducerConsumerCollection.cs
- IODescriptionAttribute.cs
- PeerUnsafeNativeCryptMethods.cs
- TextServicesDisplayAttributePropertyRanges.cs
- PowerModeChangedEventArgs.cs
- WorkflowServiceBuildProvider.cs
- CompiledELinqQueryState.cs
- ParserContext.cs
- AppDomainEvidenceFactory.cs
- XamlTemplateSerializer.cs
- XmlUtilWriter.cs
- FileRecordSequenceCompletedAsyncResult.cs
- ConstraintConverter.cs
- SerializationAttributes.cs
- CustomCredentialPolicy.cs
- BeginStoryboard.cs
- FixedSOMTableCell.cs
- PropertyEmitter.cs
- SrgsText.cs
- templategroup.cs
- KeyToListMap.cs
- DelegatingTypeDescriptionProvider.cs
- ExpressionEditor.cs
- RuntimeArgumentHandle.cs
- OdbcCommandBuilder.cs
- RemoteCryptoDecryptRequest.cs
- XPathSingletonIterator.cs
- TiffBitmapEncoder.cs
- DataGridColumn.cs
- ConstraintConverter.cs
- KnownBoxes.cs
- RawContentTypeMapper.cs
- StatusBar.cs
- TypeBuilder.cs
- AddingNewEventArgs.cs
- ShaderEffect.cs
- DataConnectionHelper.cs
- AuthenticatingEventArgs.cs
- MetadataHelper.cs
- RangeContentEnumerator.cs
- ClientScriptManager.cs
- TreeViewAutomationPeer.cs
- EmbossBitmapEffect.cs
- WindowsScroll.cs
- AllMembershipCondition.cs
- SHA1Cng.cs
- RtfControls.cs
- Rule.cs
- CommonDialog.cs
- ScrollBar.cs
- FreezableDefaultValueFactory.cs
- TextContainerChangeEventArgs.cs
- ItemsPresenter.cs
- SQLConvert.cs
- KeyedCollection.cs
- Win32KeyboardDevice.cs
- DataSourceSelectArguments.cs
- PassportAuthenticationEventArgs.cs
- designeractionbehavior.cs
- NetCodeGroup.cs