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
- HitTestParameters3D.cs
- VisualStyleInformation.cs
- ListBindingHelper.cs
- FlowLayoutPanel.cs
- ResourceDisplayNameAttribute.cs
- HttpHandlerActionCollection.cs
- OneWayBindingElement.cs
- AncillaryOps.cs
- TextServicesContext.cs
- RewritingPass.cs
- SQLInt64.cs
- CacheSection.cs
- AliasedSlot.cs
- SecurityAlgorithmSuiteConverter.cs
- WebPartZoneCollection.cs
- ListViewEditEventArgs.cs
- PermissionToken.cs
- SetterBase.cs
- EventLog.cs
- InternalBufferOverflowException.cs
- EntityParameter.cs
- HealthMonitoringSectionHelper.cs
- ValidationError.cs
- AudioLevelUpdatedEventArgs.cs
- MenuItem.cs
- DataGridTableCollection.cs
- CodeBlockBuilder.cs
- formatstringdialog.cs
- InvalidDataException.cs
- AnnotationAuthorChangedEventArgs.cs
- CatalogZone.cs
- InputMethodStateChangeEventArgs.cs
- KnownBoxes.cs
- HttpCapabilitiesEvaluator.cs
- UnsafeMethods.cs
- DataSourceControl.cs
- OutputCacheSettingsSection.cs
- KeyGesture.cs
- SoapObjectReader.cs
- ListMarkerLine.cs
- ContentDefinition.cs
- BinaryFormatter.cs
- AccessorTable.cs
- EdmRelationshipNavigationPropertyAttribute.cs
- IIS7WorkerRequest.cs
- BindingValueChangedEventArgs.cs
- BlockingCollection.cs
- CompleteWizardStep.cs
- DirtyTextRange.cs
- RepeatButton.cs
- ActivityValidationServices.cs
- DSASignatureFormatter.cs
- WebPartVerbsEventArgs.cs
- Menu.cs
- HttpServerUtilityWrapper.cs
- OLEDB_Util.cs
- EmptyStringExpandableObjectConverter.cs
- Metadata.cs
- mongolianshape.cs
- AutomationPropertyInfo.cs
- ProfileParameter.cs
- HostedAspNetEnvironment.cs
- base64Transforms.cs
- NonVisualControlAttribute.cs
- TraceContext.cs
- TextContainerHelper.cs
- ISCIIEncoding.cs
- RtfToken.cs
- SignatureResourceHelper.cs
- NaturalLanguageHyphenator.cs
- Module.cs
- ContentHostHelper.cs
- PixelShader.cs
- ColumnHeader.cs
- InternalDuplexBindingElement.cs
- MultiAsyncResult.cs
- ObsoleteAttribute.cs
- LayoutExceptionEventArgs.cs
- ClientConvert.cs
- WindowsRebar.cs
- XmlComment.cs
- URLMembershipCondition.cs
- ControlBindingsCollection.cs
- DataGridHeaderBorder.cs
- EdmFunction.cs
- AsymmetricSignatureDeformatter.cs
- StylusPointPropertyInfoDefaults.cs
- Thumb.cs
- AuthorizationContext.cs
- FusionWrap.cs
- AutomationEvent.cs
- ValidationManager.cs
- SelectionRangeConverter.cs
- DataColumnChangeEvent.cs
- SubpageParagraph.cs
- ItemList.cs
- SchemaLookupTable.cs
- FileAuthorizationModule.cs
- AutomationElementCollection.cs
- XmlnsCache.cs