Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / ndp / fx / src / Net / System / Net / Mail / DelegatedStream.cs / 1 / DelegatedStream.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net { using System; using System.Net.Sockets; using System.IO; internal class DelegatedStream : Stream { Stream stream; NetworkStream netStream; protected DelegatedStream() { } protected DelegatedStream(Stream stream) { if (stream == null) throw new ArgumentNullException("stream"); this.stream = stream; netStream = stream as NetworkStream; } protected Stream BaseStream { get { return this.stream; } } public override bool CanRead { get { return this.stream.CanRead; } } public override bool CanSeek { get { return this.stream.CanSeek; } } public override bool CanWrite { get { return this.stream.CanWrite; } } public override long Length { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Length; } } public override long Position { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Position; } set { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.Position = value; } } public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginRead (buffer, offset, count, callback, state); } else{ result = this.stream.BeginRead (buffer, offset, count, callback, state); } return result; } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginWrite(buffer, offset, count, callback, state); } else{ result = this.stream.BeginWrite (buffer, offset, count, callback, state); } return result; } //This calls close on the inner stream //however, the stream may not be actually closed, but simpy flushed public override void Close() { this.stream.Close(); } public override int EndRead(IAsyncResult asyncResult) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.EndRead (asyncResult); return read; } public override void EndWrite(IAsyncResult asyncResult) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.EndWrite (asyncResult); } public override void Flush() { this.stream.Flush(); } public override int Read(byte[] buffer, int offset, int count) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.Read(buffer, offset, count); return read; } public override long Seek(long offset, SeekOrigin origin) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); long position = this.stream.Seek(offset, origin); return position; } public override void SetLength(long value) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.SetLength(value); } public override void Write(byte[] buffer, int offset, int count) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.Write(buffer, offset, count); } } }
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- LicenseContext.cs
- DataGridSortCommandEventArgs.cs
- GB18030Encoding.cs
- NullableFloatMinMaxAggregationOperator.cs
- GraphicsPathIterator.cs
- ChangeBlockUndoRecord.cs
- RadioButtonAutomationPeer.cs
- ChannelDispatcherBase.cs
- ResourceCategoryAttribute.cs
- Timer.cs
- PublishLicense.cs
- ListSurrogate.cs
- GraphicsPath.cs
- BufferBuilder.cs
- WebControlsSection.cs
- ValidationRuleCollection.cs
- LexicalChunk.cs
- AnimatedTypeHelpers.cs
- StringDictionaryCodeDomSerializer.cs
- Int16KeyFrameCollection.cs
- DataSourceControlBuilder.cs
- PenThread.cs
- CodeStatement.cs
- FrameworkContextData.cs
- Label.cs
- QuaternionKeyFrameCollection.cs
- ViewPort3D.cs
- IssuanceLicense.cs
- WebPartDisplayMode.cs
- BrowserInteropHelper.cs
- Popup.cs
- NavigatorInput.cs
- DataControlField.cs
- Sorting.cs
- XmlToDatasetMap.cs
- ExceptionUtil.cs
- TransportContext.cs
- ScaleTransform.cs
- Point.cs
- UpdatePanelTriggerCollection.cs
- XmlSchemaCompilationSettings.cs
- _emptywebproxy.cs
- FrameworkElement.cs
- Function.cs
- DataGridLinkButton.cs
- SQLCharsStorage.cs
- ElementAtQueryOperator.cs
- BevelBitmapEffect.cs
- ToolbarAUtomationPeer.cs
- CategoryNameCollection.cs
- KeyMatchBuilder.cs
- SqlOuterApplyReducer.cs
- WMIInterop.cs
- sqlser.cs
- CurrencyManager.cs
- versioninfo.cs
- MemoryMappedViewAccessor.cs
- DiscoveryProxy.cs
- _FtpControlStream.cs
- Oid.cs
- XmlSchemaSimpleTypeUnion.cs
- XamlWrapperReaders.cs
- BinaryFormatterWriter.cs
- ScopeElement.cs
- SHA512Managed.cs
- StateManager.cs
- HotCommands.cs
- ProcessHost.cs
- HierarchicalDataBoundControlAdapter.cs
- HttpCachePolicy.cs
- PropertyGroupDescription.cs
- CellLabel.cs
- HelloOperationCD1AsyncResult.cs
- Resources.Designer.cs
- Function.cs
- UInt64.cs
- MenuAdapter.cs
- CanonicalXml.cs
- WindowsToolbar.cs
- SapiRecoInterop.cs
- ObjectStateFormatter.cs
- _TransmitFileOverlappedAsyncResult.cs
- StringResourceManager.cs
- HasRunnableWorkflowEvent.cs
- SecurityElement.cs
- AppSettingsExpressionBuilder.cs
- SimpleHandlerBuildProvider.cs
- ParagraphResult.cs
- FullTextBreakpoint.cs
- PublisherMembershipCondition.cs
- NeutralResourcesLanguageAttribute.cs
- QueryOpeningEnumerator.cs
- ConcurrentQueue.cs
- Brush.cs
- DesignerActionUIStateChangeEventArgs.cs
- ImageUrlEditor.cs
- TextEncodedRawTextWriter.cs
- QilPatternFactory.cs
- BasicDesignerLoader.cs
- DataBindingsDialog.cs