Code:
/ DotNET / DotNET / 8.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
- XmlBufferedByteStreamReader.cs
- EntityDesignerDataSourceView.cs
- HashAlgorithm.cs
- ErrorHandler.cs
- ClrPerspective.cs
- DataGridViewAdvancedBorderStyle.cs
- BaseCAMarshaler.cs
- BlurBitmapEffect.cs
- BitmapFrameDecode.cs
- SimpleLine.cs
- MaskDesignerDialog.cs
- OneToOneMappingSerializer.cs
- CodeSnippetExpression.cs
- ColumnBinding.cs
- DataGridViewRowCollection.cs
- AppSecurityManager.cs
- ScriptResourceDefinition.cs
- SafeCryptContextHandle.cs
- QueryableFilterRepeater.cs
- OleDbTransaction.cs
- Soap.cs
- TransformGroup.cs
- MultipleCopiesCollection.cs
- UnsafeNativeMethods.cs
- CaseExpr.cs
- StringUtil.cs
- PreservationFileReader.cs
- RegexTypeEditor.cs
- UriSectionData.cs
- BookmarkScopeManager.cs
- BinaryOperationBinder.cs
- QilCloneVisitor.cs
- FileLogRecordHeader.cs
- XamlReaderHelper.cs
- ExpressionBuilder.cs
- SmtpTransport.cs
- DesignerHost.cs
- SessionStateContainer.cs
- ToggleButton.cs
- Validator.cs
- TextTreeTextNode.cs
- ClientApiGenerator.cs
- ErrorWebPart.cs
- VersionedStreamOwner.cs
- Types.cs
- OdbcEnvironment.cs
- ConnectorRouter.cs
- ShaderEffect.cs
- RoutedEventArgs.cs
- PerformanceCounterCategory.cs
- PagerSettings.cs
- NativeMethods.cs
- AccessText.cs
- SizeChangedEventArgs.cs
- XmlJsonWriter.cs
- TwoPhaseCommit.cs
- DataStreams.cs
- X509CertificateTokenFactoryCredential.cs
- HttpWrapper.cs
- DataGridViewComboBoxColumn.cs
- ComponentResourceKey.cs
- HttpRequestContext.cs
- StickyNoteContentControl.cs
- COM2TypeInfoProcessor.cs
- GlyphingCache.cs
- SchemaCollectionPreprocessor.cs
- AliasExpr.cs
- JavaScriptObjectDeserializer.cs
- WebPartCancelEventArgs.cs
- TableCellCollection.cs
- SrgsSemanticInterpretationTag.cs
- EdmRelationshipNavigationPropertyAttribute.cs
- SafeProcessHandle.cs
- SqlCacheDependencySection.cs
- SqlNamer.cs
- IPHostEntry.cs
- BindingManagerDataErrorEventArgs.cs
- SymmetricAlgorithm.cs
- GridViewColumnHeaderAutomationPeer.cs
- SettingsSection.cs
- TagMapCollection.cs
- ConfigXmlCDataSection.cs
- ReferentialConstraintRoleElement.cs
- PrimitiveRenderer.cs
- SafeThemeHandle.cs
- PrimaryKeyTypeConverter.cs
- ApplicationTrust.cs
- AspNetSynchronizationContext.cs
- RelationshipWrapper.cs
- SqlUserDefinedTypeAttribute.cs
- TaskbarItemInfo.cs
- StringConverter.cs
- SkipQueryOptionExpression.cs
- MethodToken.cs
- SortAction.cs
- TextAnchor.cs
- ValidatorCompatibilityHelper.cs
- FunctionGenerator.cs
- AttributeUsageAttribute.cs
- WhereQueryOperator.cs