Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// 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); } } } // 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
- Models.cs
- TextLineResult.cs
- FontDifferentiator.cs
- BorderGapMaskConverter.cs
- PenLineJoinValidation.cs
- TextEditorTables.cs
- DefaultExpression.cs
- ImageConverter.cs
- _AcceptOverlappedAsyncResult.cs
- linebase.cs
- DbConnectionPoolOptions.cs
- XmlDataCollection.cs
- CommandConverter.cs
- MulticastIPAddressInformationCollection.cs
- DataGridViewComboBoxColumn.cs
- SerialErrors.cs
- TransformerConfigurationWizardBase.cs
- XmlLoader.cs
- CompositeActivityCodeGenerator.cs
- Codec.cs
- versioninfo.cs
- TemplateKeyConverter.cs
- MetaData.cs
- ListViewHitTestInfo.cs
- WindowsSlider.cs
- UnsafePeerToPeerMethods.cs
- SrgsRule.cs
- Serializer.cs
- SqlMetaData.cs
- DateTimeParse.cs
- CreateSequence.cs
- FloaterParaClient.cs
- AddInAdapter.cs
- Parser.cs
- ThreadExceptionEvent.cs
- DataBindingCollection.cs
- XhtmlBasicPhoneCallAdapter.cs
- SqlServices.cs
- WhereQueryOperator.cs
- SqlDataAdapter.cs
- CriticalHandle.cs
- AnnotationAuthorChangedEventArgs.cs
- EntityDesignerBuildProvider.cs
- DBAsyncResult.cs
- BitmapMetadataEnumerator.cs
- Operand.cs
- OracleTimeSpan.cs
- EditorAttribute.cs
- UnsafeNativeMethodsMilCoreApi.cs
- RealizationDrawingContextWalker.cs
- ThreadInterruptedException.cs
- EnumUnknown.cs
- ObjectDataSourceDisposingEventArgs.cs
- ListenerElementsCollection.cs
- DbParameterCollection.cs
- TrackingDataItem.cs
- ConcurrentBag.cs
- SpellerInterop.cs
- BuildProvider.cs
- SignalGate.cs
- DesignerWidgets.cs
- RadioButtonList.cs
- AccessKeyManager.cs
- CustomAttributeBuilder.cs
- Rotation3DAnimationUsingKeyFrames.cs
- ExtensionDataObject.cs
- CompilerGlobalScopeAttribute.cs
- TemplatedWizardStep.cs
- OdbcFactory.cs
- SqlCacheDependencyDatabaseCollection.cs
- MembershipUser.cs
- SerializationSectionGroup.cs
- DefaultProxySection.cs
- DropDownList.cs
- PropertyDescriptor.cs
- LinearGradientBrush.cs
- LogRestartAreaEnumerator.cs
- MonitorWrapper.cs
- SimpleApplicationHost.cs
- OleDbMetaDataFactory.cs
- handlecollector.cs
- DynamicResourceExtension.cs
- ApplicationFileParser.cs
- InvalidOleVariantTypeException.cs
- PhysicalAddress.cs
- ApplicationManager.cs
- MasterPage.cs
- StickyNoteHelper.cs
- TagPrefixInfo.cs
- latinshape.cs
- HttpBufferlessInputStream.cs
- ActiveXSite.cs
- ExtentCqlBlock.cs
- ExportOptions.cs
- WebBrowserUriTypeConverter.cs
- IEnumerable.cs
- SqlDataSourceSelectingEventArgs.cs
- ErrorsHelper.cs
- WrappedIUnknown.cs
- XmlAnyAttributeAttribute.cs