diff --git a/std/socketstream.d b/std/socketstream.d index 3032a53c3..789e1fa64 100644 --- a/std/socketstream.d +++ b/std/socketstream.d @@ -21,8 +21,8 @@ */ /************** - * SocketStream is a stream for a blocking, - * connected Socket. + * $(D SocketStream) is a stream for a blocking, + * connected $(D Socket). * * For Win32 systems, link with ws2_32.lib. * @@ -41,8 +41,8 @@ private import std.stream; private import std.socket; /************** - * SocketStream is a stream for a blocking, - * connected Socket. + * $(D SocketStream) is a stream for a blocking, + * connected $(D Socket). */ class SocketStream: Stream { @@ -56,29 +56,29 @@ class SocketStream: Stream */ this(Socket sock, FileMode mode) { - if(mode & FileMode.In) - readable = true; - if(mode & FileMode.Out) - writeable = true; + if(mode & FileMode.In) + readable = true; + if(mode & FileMode.Out) + writeable = true; - this.sock = sock; + this.sock = sock; } /** - * Uses mode FileMode.In | FileMode.Out. + * Uses mode $(D FileMode.In | FileMode.Out). */ this(Socket sock) { - writeable = readable = true; - this.sock = sock; + writeable = readable = true; + this.sock = sock; } /** - * Property to get the Socket that is being streamed. + * Property to get the $(D Socket) that is being streamed. */ Socket socket() { - return sock; + return sock; } /** @@ -86,17 +86,17 @@ class SocketStream: Stream */ override size_t readBlock(void* _buffer, size_t size) { - ubyte* buffer = cast(ubyte*)_buffer; - assertReadable(); + ubyte* buffer = cast(ubyte*)_buffer; + assertReadable(); - if (size == 0) - return size; + if (size == 0) + return size; - auto len = sock.receive(buffer[0 .. size]); - readEOF = cast(bool)(len == 0); - if (len == sock.ERROR) - len = 0; - return len; + auto len = sock.receive(buffer[0 .. size]); + readEOF = cast(bool)(len == 0); + if (len == sock.ERROR) + len = 0; + return len; } /** @@ -104,17 +104,17 @@ class SocketStream: Stream */ override size_t writeBlock(const void* _buffer, size_t size) { - ubyte* buffer = cast(ubyte*)_buffer; - assertWriteable(); + ubyte* buffer = cast(ubyte*)_buffer; + assertWriteable(); - if (size == 0) - return size; + if (size == 0) + return size; - auto len = sock.send(buffer[0 .. size]); - readEOF = cast(bool)(len == 0); - if (len == sock.ERROR) - len = 0; - return len; + auto len = sock.send(buffer[0 .. size]); + readEOF = cast(bool)(len == 0); + if (len == sock.ERROR) + len = 0; + return len; } /** @@ -122,7 +122,7 @@ class SocketStream: Stream */ override ulong seek(long offset, SeekPos whence) { - throw new SeekException("Cannot seek a socket."); + throw new SeekException("Cannot seek a socket."); } /** @@ -131,15 +131,15 @@ class SocketStream: Stream */ override string toString() { - return sock.toString(); + return sock.toString(); } /** - * Close the Socket. + * Close the $(D Socket). */ override void close() { - sock.close(); + sock.close(); } }