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
- CodeMethodInvokeExpression.cs
- SqlFactory.cs
- EntityStoreSchemaFilterEntry.cs
- MessageSmuggler.cs
- SubqueryRules.cs
- SecurityRuntime.cs
- ManagementQuery.cs
- ProjectionPruner.cs
- Span.cs
- SourceExpressionException.cs
- MimeFormatExtensions.cs
- NamedElement.cs
- TypeSource.cs
- XmlSignatureManifest.cs
- DbSource.cs
- StateRuntime.cs
- MachineKeySection.cs
- Splitter.cs
- FragmentQueryProcessor.cs
- WebPartCancelEventArgs.cs
- View.cs
- DbConnectionPoolIdentity.cs
- WebControl.cs
- StackSpiller.Temps.cs
- InternalDispatchObject.cs
- SemaphoreSecurity.cs
- ServiceBehaviorElement.cs
- CommonDialog.cs
- RelationshipFixer.cs
- AuthenticationException.cs
- FrameworkTextComposition.cs
- ActiveXSerializer.cs
- GeneratedView.cs
- GregorianCalendar.cs
- mda.cs
- AbstractDataSvcMapFileLoader.cs
- HtmlEncodedRawTextWriter.cs
- TranslateTransform3D.cs
- VirtualPathUtility.cs
- DesignerHelpers.cs
- DocumentPageHost.cs
- CheckBox.cs
- filewebrequest.cs
- Context.cs
- DataGridrowEditEndingEventArgs.cs
- XmlComment.cs
- HandlerFactoryCache.cs
- RegexStringValidator.cs
- MenuAutomationPeer.cs
- FixedBufferAttribute.cs
- BindingWorker.cs
- EventProviderWriter.cs
- DataGridPageChangedEventArgs.cs
- MailWriter.cs
- IgnoreSectionHandler.cs
- ScrollEvent.cs
- AuthenticationService.cs
- InputLanguageCollection.cs
- MessageRpc.cs
- PropertyDescriptorGridEntry.cs
- BamlRecordReader.cs
- ExpressionBuilder.cs
- EntityClientCacheKey.cs
- FusionWrap.cs
- ResourceContainerWrapper.cs
- SchemaElementLookUpTableEnumerator.cs
- Mapping.cs
- CommandSet.cs
- RC2CryptoServiceProvider.cs
- ListViewItem.cs
- EntityDataSourceViewSchema.cs
- ObjectMemberMapping.cs
- UserValidatedEventArgs.cs
- CodeStatementCollection.cs
- LazyTextWriterCreator.cs
- URLIdentityPermission.cs
- MissingMethodException.cs
- HttpCacheVaryByContentEncodings.cs
- OdbcCommand.cs
- DomNameTable.cs
- InputDevice.cs
- XmlSchemaObjectCollection.cs
- NotFiniteNumberException.cs
- ValueQuery.cs
- PenLineJoinValidation.cs
- SizeLimitedCache.cs
- SiteMapPath.cs
- StrongNamePublicKeyBlob.cs
- DbCommandTree.cs
- SQLBinaryStorage.cs
- WebPartVerb.cs
- PageBreakRecord.cs
- SiteMapDataSource.cs
- ASCIIEncoding.cs
- XsdCachingReader.cs
- BufferBuilder.cs
- StickyNote.cs
- DeferredRunTextReference.cs
- BridgeDataRecord.cs
- BaseEntityWrapper.cs