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
- BamlRecordWriter.cs
- TextBox.cs
- UnsafeNativeMethods.cs
- HtmlElementErrorEventArgs.cs
- FuncTypeConverter.cs
- SimpleWorkerRequest.cs
- PresentationSource.cs
- MouseActionConverter.cs
- WebBrowserSiteBase.cs
- SamlSerializer.cs
- ModelPropertyCollectionImpl.cs
- TypeNameParser.cs
- ControlAdapter.cs
- AssemblyFilter.cs
- ObjectAssociationEndMapping.cs
- LeaseManager.cs
- MimeImporter.cs
- SelectedGridItemChangedEvent.cs
- AspNetSynchronizationContext.cs
- BitmapData.cs
- DataServiceQueryException.cs
- ReversePositionQuery.cs
- DataServiceQueryOfT.cs
- SocketConnection.cs
- TemplatedAdorner.cs
- ValidationRuleCollection.cs
- Matrix.cs
- DPTypeDescriptorContext.cs
- mactripleDES.cs
- ClientBuildManagerCallback.cs
- DesigntimeLicenseContext.cs
- _Events.cs
- TableCellsCollectionEditor.cs
- ToolStripButton.cs
- TraceListener.cs
- AssertUtility.cs
- OleDbCommandBuilder.cs
- ObjectDataSourceSelectingEventArgs.cs
- TemplatedEditableDesignerRegion.cs
- RevocationPoint.cs
- DeploymentSection.cs
- SatelliteContractVersionAttribute.cs
- InputMethodStateChangeEventArgs.cs
- TypeBuilderInstantiation.cs
- WinFormsSpinner.cs
- PriorityBinding.cs
- NativeMethods.cs
- ObjectIDGenerator.cs
- XamlVector3DCollectionSerializer.cs
- HandlerBase.cs
- TextPointer.cs
- XslException.cs
- HttpModule.cs
- MappingSource.cs
- SingleResultAttribute.cs
- AsyncCompletedEventArgs.cs
- xmlsaver.cs
- RegistryDataKey.cs
- UTF32Encoding.cs
- BreakRecordTable.cs
- AnimatedTypeHelpers.cs
- SessionStateUtil.cs
- TypeBinaryExpression.cs
- FormParameter.cs
- CollaborationHelperFunctions.cs
- OleDbError.cs
- RelationshipDetailsRow.cs
- MsmqBindingElementBase.cs
- MenuItemCollectionEditorDialog.cs
- CustomActivityDesigner.cs
- ToolStripPanelRow.cs
- GenericUriParser.cs
- ApplicationInterop.cs
- SqlServer2KCompatibilityAnnotation.cs
- SqlCommandSet.cs
- TextTreeTextElementNode.cs
- KeyValueConfigurationCollection.cs
- SocketCache.cs
- SqlTriggerContext.cs
- WebAdminConfigurationHelper.cs
- Semaphore.cs
- Help.cs
- ObjectDataSourceFilteringEventArgs.cs
- FamilyMapCollection.cs
- CellParagraph.cs
- Timer.cs
- DefaultValueTypeConverter.cs
- AppDomainGrammarProxy.cs
- ControlCachePolicy.cs
- SoapAttributes.cs
- DataRowCollection.cs
- SerializableAuthorizationContext.cs
- DiscoveryMessageProperty.cs
- Unit.cs
- SafeRightsManagementEnvironmentHandle.cs
- ObjectDataSourceSelectingEventArgs.cs
- DataGridViewCellToolTipTextNeededEventArgs.cs
- CommandArguments.cs
- DbXmlEnabledProviderManifest.cs
- MarkupCompiler.cs