deavmi/river
deavmi
/
river
mirror of https://github.com/deavmi/river
1
0
Fork 0
Code Issues Releases Activity

FDStream 

- Corrected error messages for `read` and `readFully`
- Added `write(byte[])` implementation
This commit is contained in:
Tristan B. Velloza Kildaire 2023-04-29 16:32:56 +02:00
parent ec46b26a5f
commit f87cfb76e5
1 changed files with 36 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
source/river/impls/fd.d
View File

@ -57,7 +57,7 @@ public abstract class FDStream : Stream
}
else
{
pragma(msg, "PipeStream: The read() call is not implemented for your platform");
pragma(msg, "FDStream: The read() call is not implemented for your platform");
static assert(false);
}
}
@ -105,11 +105,45 @@ public abstract class FDStream : Stream
}
else
{
pragma(msg, "PipeStream: The readFully() call is not implemented for your platform");
pragma(msg, "FDStream: The readFully() call is not implemented for your platform");
static assert(false);
}
}
public override ulong write(byte[] fromArray)
{
version(Posix)
{
import core.sys.posix.unistd : write, ssize_t;
ssize_t status = write(fd, fromArray.ptr, fromArray.length);
if(status > 0)
{
return status;
}
else if(status == 0)
{
throw new StreamException(StreamError.OPERATION_FAILED, "Could not write, status 0");
}
else
{
throw new StreamException(StreamError.OPERATION_FAILED, "Could not write, status <0");
}
}
else
{
pragma(msg, "FDStream: The write() call is not implemented for your platform");
static assert(false);
}
}
public override ulong writeFully(byte[] fromArray)
{
// TODO: Implement me
return 0;
}
/**
* Closes the file descriptor
*/