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
- AuthorizationRule.cs
- TransactionFlowBindingElementImporter.cs
- ReadOnlyDictionary.cs
- ParentQuery.cs
- ProcessModelSection.cs
- CompressionTransform.cs
- AliasedSlot.cs
- BamlLocalizableResource.cs
- UrlMapping.cs
- QilExpression.cs
- DefaultExpression.cs
- ZipIORawDataFileBlock.cs
- SecureStringHasher.cs
- OperatorExpressions.cs
- InvalidPrinterException.cs
- MetadataPropertyvalue.cs
- DiscreteKeyFrames.cs
- StylusPointProperties.cs
- DependencyPropertyDescriptor.cs
- ConditionalWeakTable.cs
- BezierSegment.cs
- PersonalizationDictionary.cs
- SplineKeyFrames.cs
- PersianCalendar.cs
- ZipPackagePart.cs
- OrderedEnumerableRowCollection.cs
- LineBreakRecord.cs
- PtsContext.cs
- MemberInfoSerializationHolder.cs
- RangeValuePatternIdentifiers.cs
- WindowsSysHeader.cs
- TypeElement.cs
- DefaultAssemblyResolver.cs
- WindowsTooltip.cs
- DrawingServices.cs
- CodeDelegateInvokeExpression.cs
- XmlTypeAttribute.cs
- DataMemberListEditor.cs
- AnonymousIdentificationSection.cs
- DesignerSerializationManager.cs
- ExternalCalls.cs
- DirectoryInfo.cs
- SessionEndedEventArgs.cs
- CommunicationObjectAbortedException.cs
- Compiler.cs
- DefaultCommandConverter.cs
- IntegerValidator.cs
- NullReferenceException.cs
- BasicExpandProvider.cs
- SecureUICommand.cs
- CleanUpVirtualizedItemEventArgs.cs
- XmlIgnoreAttribute.cs
- CodeCastExpression.cs
- PersistChildrenAttribute.cs
- GridViewActionList.cs
- UrlMappingsSection.cs
- MenuAdapter.cs
- Icon.cs
- OutputCacheEntry.cs
- BasicBrowserDialog.designer.cs
- RegexCharClass.cs
- ToolStripContainerDesigner.cs
- ZipIOCentralDirectoryFileHeader.cs
- FilterElement.cs
- ListItem.cs
- XmlWrappingWriter.cs
- ArrayExtension.cs
- SerialReceived.cs
- LassoSelectionBehavior.cs
- Parameter.cs
- FlowThrottle.cs
- StringInfo.cs
- DispatcherHooks.cs
- _ConnectionGroup.cs
- IteratorDescriptor.cs
- ObjectItemAttributeAssemblyLoader.cs
- XmlnsDictionary.cs
- PerspectiveCamera.cs
- Floater.cs
- DrawingContextDrawingContextWalker.cs
- DependencyPropertyAttribute.cs
- NonParentingControl.cs
- NumericUpDownAccelerationCollection.cs
- DefaultHttpHandler.cs
- Error.cs
- SourceFileBuildProvider.cs
- ObjectItemCachedAssemblyLoader.cs
- EntitySet.cs
- XhtmlConformanceSection.cs
- DatePickerAutomationPeer.cs
- SafeThreadHandle.cs
- ResourceDescriptionAttribute.cs
- StorageEntityTypeMapping.cs
- DecimalConstantAttribute.cs
- ResolvedKeyFrameEntry.cs
- ConditionalAttribute.cs
- CodeMemberField.cs
- WebConfigurationManager.cs
- HttpEncoder.cs
- AtomServiceDocumentSerializer.cs