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
- CompilationUnit.cs
- BamlTreeNode.cs
- AccessibleObject.cs
- FileSystemWatcher.cs
- DataRowComparer.cs
- CommandLibraryHelper.cs
- XomlSerializationHelpers.cs
- Membership.cs
- ConnectionConsumerAttribute.cs
- ErrorsHelper.cs
- OracleMonthSpan.cs
- ProfessionalColorTable.cs
- ComponentCodeDomSerializer.cs
- WebPartConnectionsCloseVerb.cs
- SeekableReadStream.cs
- TransformerInfo.cs
- WebPartHelpVerb.cs
- TrackingMemoryStreamFactory.cs
- XmlMapping.cs
- FirewallWrapper.cs
- EncoderReplacementFallback.cs
- Debugger.cs
- Logging.cs
- HttpFormatExtensions.cs
- DataViewManager.cs
- CultureTable.cs
- EventDescriptorCollection.cs
- DocumentProperties.cs
- QueryResponse.cs
- embossbitmapeffect.cs
- EditorAttribute.cs
- Axis.cs
- ListControl.cs
- Point3DCollectionConverter.cs
- OleDbParameter.cs
- FilteredAttributeCollection.cs
- _DisconnectOverlappedAsyncResult.cs
- ParameterCollection.cs
- Root.cs
- InvalidCastException.cs
- XamlStream.cs
- PersistenceTypeAttribute.cs
- XmlAnyAttributeAttribute.cs
- PrintPageEvent.cs
- ActivityXRefPropertyEditor.cs
- QilReplaceVisitor.cs
- SecurityRuntime.cs
- CharStorage.cs
- TextRenderer.cs
- TracePayload.cs
- ValidatingCollection.cs
- ClientData.cs
- CodeNamespace.cs
- RewritingPass.cs
- SHA384.cs
- SynchronousChannelMergeEnumerator.cs
- TypeExtensions.cs
- PropertyPath.cs
- CorrelationQuery.cs
- DocumentEventArgs.cs
- ConvertEvent.cs
- FixedTextBuilder.cs
- StylusPointPropertyInfoDefaults.cs
- WebPartHelpVerb.cs
- DiagnosticTrace.cs
- ListView.cs
- RtfToken.cs
- ContainerSelectorActiveEvent.cs
- GridViewColumnCollection.cs
- DuplicateWaitObjectException.cs
- MulticastOption.cs
- LoginCancelEventArgs.cs
- SystemColors.cs
- XmlHelper.cs
- Transform.cs
- StringDictionaryWithComparer.cs
- CodeTypeReference.cs
- DragCompletedEventArgs.cs
- InputReportEventArgs.cs
- ToolStripOverflow.cs
- SmiEventStream.cs
- MenuItemStyle.cs
- CancelEventArgs.cs
- PropertyTabChangedEvent.cs
- SetterBaseCollection.cs
- RequestUriProcessor.cs
- GridViewColumn.cs
- XamlParser.cs
- IndexedEnumerable.cs
- WebPartConnectionCollection.cs
- SpecularMaterial.cs
- ListViewGroupConverter.cs
- ImageKeyConverter.cs
- Vector3DKeyFrameCollection.cs
- HttpModuleActionCollection.cs
- SamlSubjectStatement.cs
- Expressions.cs
- MultipartContentParser.cs
- ObjectStateManagerMetadata.cs
- TimeZone.cs