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
- GridViewRowCollection.cs
- TypeContext.cs
- ResourceType.cs
- WriteableOnDemandPackagePart.cs
- FormViewPagerRow.cs
- UIntPtr.cs
- UnsafeNativeMethods.cs
- BindingMemberInfo.cs
- RegexBoyerMoore.cs
- Parallel.cs
- DataSourceControl.cs
- QilCloneVisitor.cs
- KnownAssembliesSet.cs
- DataGridViewToolTip.cs
- LookupBindingPropertiesAttribute.cs
- DefaultConfirmation.cs
- SByteConverter.cs
- TextEditorThreadLocalStore.cs
- WorkflowMarkupElementEventArgs.cs
- SqlBulkCopyColumnMappingCollection.cs
- Size.cs
- TransformerInfoCollection.cs
- AssemblyInfo.cs
- DebugView.cs
- RecordsAffectedEventArgs.cs
- ToggleButtonAutomationPeer.cs
- AccessDataSourceView.cs
- ConnectionManagementElement.cs
- ControlCachePolicy.cs
- RegexFCD.cs
- EmptyQuery.cs
- ResourceDictionaryCollection.cs
- Timer.cs
- KeysConverter.cs
- RsaSecurityTokenParameters.cs
- GridSplitter.cs
- ControlPaint.cs
- SqlCacheDependencySection.cs
- ZoneLinkButton.cs
- WhitespaceRuleReader.cs
- Animatable.cs
- BitmapEffectGroup.cs
- OleDbTransaction.cs
- GrammarBuilderPhrase.cs
- Operator.cs
- Point3DAnimationBase.cs
- DataGridHeaderBorder.cs
- SequentialUshortCollection.cs
- BaseValidator.cs
- EntitySet.cs
- StylusButtonEventArgs.cs
- Html32TextWriter.cs
- AsmxEndpointPickerExtension.cs
- TraceSwitch.cs
- ResourcePool.cs
- ViewManager.cs
- RSAPKCS1KeyExchangeFormatter.cs
- ChannelSinkStacks.cs
- ScalarConstant.cs
- MouseGestureValueSerializer.cs
- SoapSchemaMember.cs
- ItemChangedEventArgs.cs
- EntityKey.cs
- PixelFormats.cs
- ControlCodeDomSerializer.cs
- Canvas.cs
- XmlRawWriterWrapper.cs
- TextCollapsingProperties.cs
- DesignerSerializerAttribute.cs
- CharacterMetrics.cs
- XDRSchema.cs
- AbstractExpressions.cs
- GeometryCollection.cs
- ReachSerializer.cs
- __Error.cs
- ExtendedPropertiesHandler.cs
- AnimatedTypeHelpers.cs
- GridViewItemAutomationPeer.cs
- ConsoleCancelEventArgs.cs
- ParameterModifier.cs
- ImageListUtils.cs
- CodeAttributeDeclarationCollection.cs
- ScriptControlManager.cs
- CachedPathData.cs
- ScriptManager.cs
- XmlAutoDetectWriter.cs
- BeginEvent.cs
- SessionStateUtil.cs
- WindowsListViewGroup.cs
- AVElementHelper.cs
- DiagnosticTraceSource.cs
- ResourceExpressionBuilder.cs
- CodeCompileUnit.cs
- ListItemCollection.cs
- FlowPanelDesigner.cs
- VoiceChangeEventArgs.cs
- DerivedKeySecurityTokenStub.cs
- RequestCacheValidator.cs
- UnionQueryOperator.cs
- ScrollBar.cs