Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Net / System / Net / Mail / DelegatedStream.cs / 1305376 / 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.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- _Connection.cs
- TextRunTypographyProperties.cs
- OSEnvironmentHelper.cs
- EditorPartCollection.cs
- UIElementIsland.cs
- DesignerCatalogPartChrome.cs
- WebBrowserSiteBase.cs
- OdbcTransaction.cs
- GlyphCache.cs
- CellParagraph.cs
- SerializationObjectManager.cs
- HttpModuleCollection.cs
- ShaderRenderModeValidation.cs
- compensatingcollection.cs
- BitmapEffectState.cs
- SQLInt64.cs
- BindingMAnagerBase.cs
- StylusPlugInCollection.cs
- MSAAEventDispatcher.cs
- TableCell.cs
- FrameworkContentElementAutomationPeer.cs
- DataGridViewCellPaintingEventArgs.cs
- DiagnosticsConfigurationHandler.cs
- UTF32Encoding.cs
- DecoderNLS.cs
- PatternMatchRules.cs
- ActivityCodeDomSerializer.cs
- MoveSizeWinEventHandler.cs
- SuppressIldasmAttribute.cs
- PermissionSet.cs
- DataGridViewSelectedColumnCollection.cs
- XmlAttributes.cs
- CompoundFileReference.cs
- XXXOnTypeBuilderInstantiation.cs
- XmlTextEncoder.cs
- PagedDataSource.cs
- ControlValuePropertyAttribute.cs
- ProcessRequestArgs.cs
- EasingQuaternionKeyFrame.cs
- DisplayMemberTemplateSelector.cs
- KeyFrames.cs
- MarkupCompiler.cs
- ProcessManager.cs
- BaseValidator.cs
- SymLanguageVendor.cs
- BitStack.cs
- XmlSchemaDocumentation.cs
- CopyCodeAction.cs
- TCPListener.cs
- TextServicesCompartment.cs
- CodeDomComponentSerializationService.cs
- TextServicesManager.cs
- DiscreteKeyFrames.cs
- AuthStoreRoleProvider.cs
- DataKeyCollection.cs
- TextLineResult.cs
- MenuBase.cs
- CheckBoxFlatAdapter.cs
- AstTree.cs
- storagemappingitemcollection.viewdictionary.cs
- TraceShell.cs
- ArraySortHelper.cs
- StrokeFIndices.cs
- KeyEvent.cs
- MailBnfHelper.cs
- HttpWebResponse.cs
- FunctionDetailsReader.cs
- ObjectItemCollection.cs
- _HTTPDateParse.cs
- Application.cs
- Stacktrace.cs
- HierarchicalDataBoundControlAdapter.cs
- XmlSchemaIdentityConstraint.cs
- DeclarationUpdate.cs
- RectangleGeometry.cs
- SafeNativeMethods.cs
- TypeElementCollection.cs
- DataContractSerializer.cs
- CqlParserHelpers.cs
- ControlEvent.cs
- DependencyPropertyValueSerializer.cs
- StorageComplexTypeMapping.cs
- BaseDataListDesigner.cs
- QueryCursorEventArgs.cs
- FixUp.cs
- Binding.cs
- XmlSignificantWhitespace.cs
- CharKeyFrameCollection.cs
- HyperLink.cs
- HelpProvider.cs
- DrawingCollection.cs
- FlowDocumentPaginator.cs
- ClientApiGenerator.cs
- StreamUpdate.cs
- QueuePropertyVariants.cs
- TextRange.cs
- WebPartConnectionsEventArgs.cs
- DbConnectionPoolGroupProviderInfo.cs
- XmlIncludeAttribute.cs
- SymbolType.cs