Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- IERequestCache.cs
- ValidatingPropertiesEventArgs.cs
- DataSetUtil.cs
- WebPartZoneCollection.cs
- EntityDataSourceColumn.cs
- ClientTarget.cs
- ReadOnlyHierarchicalDataSourceView.cs
- GetKeyedHashRequest.cs
- InvokeMethodActivityDesigner.cs
- NetworkAddressChange.cs
- AnnotationResource.cs
- DropShadowEffect.cs
- ErrorStyle.cs
- PassportAuthenticationModule.cs
- Dump.cs
- NativeMethods.cs
- FreeFormDesigner.cs
- SimpleHandlerFactory.cs
- PointLightBase.cs
- SizeConverter.cs
- CatalogPart.cs
- PreloadHost.cs
- StorageModelBuildProvider.cs
- StateItem.cs
- InputScopeConverter.cs
- UriSection.cs
- EntityConnectionStringBuilder.cs
- PtsContext.cs
- CalendarItem.cs
- FormViewUpdatedEventArgs.cs
- AmbiguousMatchException.cs
- BindingMAnagerBase.cs
- SingletonConnectionReader.cs
- GlyphingCache.cs
- DynamicResourceExtensionConverter.cs
- GradientStopCollection.cs
- UseAttributeSetsAction.cs
- SqlDataSource.cs
- HwndSourceKeyboardInputSite.cs
- SizeAnimationClockResource.cs
- ChineseLunisolarCalendar.cs
- ColumnResult.cs
- RNGCryptoServiceProvider.cs
- SqlCacheDependencySection.cs
- CanExecuteRoutedEventArgs.cs
- DeleteCardRequest.cs
- ToolBarDesigner.cs
- SafeNativeMethodsOther.cs
- VariableQuery.cs
- DbProviderManifest.cs
- VisualStates.cs
- GridItemCollection.cs
- WorkflowRuntimeServiceElement.cs
- Context.cs
- CriticalExceptions.cs
- PropagatorResult.cs
- SafeTokenHandle.cs
- AbandonedMutexException.cs
- DependencyObject.cs
- StylusPlugInCollection.cs
- PasswordRecovery.cs
- DataTemplate.cs
- PassportIdentity.cs
- ParameterModifier.cs
- MouseGestureConverter.cs
- Formatter.cs
- WebPartEditorCancelVerb.cs
- KeyTime.cs
- SQLDateTimeStorage.cs
- ValidationErrorEventArgs.cs
- ServicePointManager.cs
- DefaultValueConverter.cs
- CookielessHelper.cs
- ClickablePoint.cs
- SqlLiftWhereClauses.cs
- _CookieModule.cs
- OLEDB_Enum.cs
- MediaPlayerState.cs
- SqlCacheDependency.cs
- DispatcherObject.cs
- OpCodes.cs
- OrderedDictionary.cs
- DataSourceXmlTextReader.cs
- ContextStaticAttribute.cs
- CaseInsensitiveOrdinalStringComparer.cs
- SafeThemeHandle.cs
- UnsafeNativeMethods.cs
- InnerItemCollectionView.cs
- DesignerVerbCollection.cs
- XamlValidatingReader.cs
- CommonRemoteMemoryBlock.cs
- PathTooLongException.cs
- BooleanSwitch.cs
- SqlBooleanizer.cs
- Vector3DKeyFrameCollection.cs
- XmlArrayItemAttributes.cs
- UserControl.cs
- LabelAutomationPeer.cs
- BehaviorEditorPart.cs
- ListComponentEditorPage.cs