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
- SqlLiftWhereClauses.cs
- RotateTransform3D.cs
- DelimitedListTraceListener.cs
- GeneralTransform3DTo2D.cs
- UrlAuthorizationModule.cs
- SourceFileBuildProvider.cs
- CompressionTransform.cs
- TypeBinaryExpression.cs
- MetabaseServerConfig.cs
- DataSourceDescriptorCollection.cs
- CharKeyFrameCollection.cs
- FontStretchConverter.cs
- recordstate.cs
- ConfigXmlCDataSection.cs
- ActivityExecutionContextCollection.cs
- WithParamAction.cs
- FixedSOMLineCollection.cs
- ClientProtocol.cs
- SurrogateSelector.cs
- Brushes.cs
- AspNetSynchronizationContext.cs
- SessionPageStatePersister.cs
- COM2IDispatchConverter.cs
- COM2FontConverter.cs
- PersonalizationStateQuery.cs
- ResourceAssociationSet.cs
- JoinGraph.cs
- RadioButtonBaseAdapter.cs
- DesignerTransaction.cs
- DateTimeParse.cs
- wmiprovider.cs
- UidManager.cs
- Compiler.cs
- ReflectionUtil.cs
- SortExpressionBuilder.cs
- TagPrefixCollection.cs
- UidPropertyAttribute.cs
- XmlElementList.cs
- CodeTypeParameterCollection.cs
- Decorator.cs
- HotSpot.cs
- XmlAnyElementAttributes.cs
- TypeReference.cs
- SqlNodeTypeOperators.cs
- StatusBarPanelClickEvent.cs
- MetadataItem.cs
- BitVector32.cs
- ContainerParagraph.cs
- COM2PropertyPageUITypeConverter.cs
- DesignerTextBoxAdapter.cs
- WebPartMovingEventArgs.cs
- TypeUtils.cs
- RootBrowserWindowAutomationPeer.cs
- VisualTarget.cs
- AnnotationResourceChangedEventArgs.cs
- ConfigurationSectionGroupCollection.cs
- WebPartEventArgs.cs
- ToolStripOverflow.cs
- SchemaElementDecl.cs
- CssClassPropertyAttribute.cs
- SafeFileMappingHandle.cs
- ModelPropertyImpl.cs
- GetImportedCardRequest.cs
- Condition.cs
- Control.cs
- EdmEntityTypeAttribute.cs
- ZipIOExtraFieldElement.cs
- FlowDocumentPage.cs
- SecurityRuntime.cs
- GridViewActionList.cs
- FindResponse.cs
- SafeTimerHandle.cs
- StylusPointDescription.cs
- BitmapImage.cs
- RootBrowserWindowProxy.cs
- MultiPropertyDescriptorGridEntry.cs
- Utility.cs
- OleDragDropHandler.cs
- TagMapCollection.cs
- ParserStreamGeometryContext.cs
- ConstraintEnumerator.cs
- RadioButtonFlatAdapter.cs
- ValidationPropertyAttribute.cs
- HiddenFieldDesigner.cs
- Logging.cs
- codemethodreferenceexpression.cs
- BindingObserver.cs
- Closure.cs
- TransactionValidationBehavior.cs
- WindowsSpinner.cs
- HashMembershipCondition.cs
- BindingGroup.cs
- MenuEventArgs.cs
- ProfileEventArgs.cs
- ProtocolsSection.cs
- SettingsPropertyNotFoundException.cs
- ToolBarButtonClickEvent.cs
- Padding.cs
- FixedSOMTable.cs
- InstanceDataCollectionCollection.cs