42 lines
1.5 KiB
Swift
42 lines
1.5 KiB
Swift
public protocol FlatBufferGRPCMessage {
|
|
|
|
/// Raw pointer which would be pointing to the beginning of the readable bytes
|
|
var rawPointer: UnsafeMutableRawPointer { get }
|
|
|
|
/// Size of readable bytes in the buffer
|
|
var size: Int { get }
|
|
|
|
init(byteBuffer: ByteBuffer)
|
|
}
|
|
|
|
/// Message is a wrapper around Buffers to to able to send Flatbuffers `Buffers` through the
|
|
/// GRPC library
|
|
public final class Message<T: FlatBufferObject>: FlatBufferGRPCMessage {
|
|
internal var buffer: ByteBuffer
|
|
|
|
/// Returns the an object of type T that would be read from the buffer
|
|
public var object: T {
|
|
T.init(buffer, o: Int32(buffer.read(def: UOffset.self, position: buffer.reader)) + Int32(buffer.reader))
|
|
}
|
|
|
|
public var rawPointer: UnsafeMutableRawPointer { return buffer.memory.advanced(by: buffer.reader) }
|
|
|
|
public var size: Int { return Int(buffer.size) }
|
|
|
|
/// Initializes the message with the type Flatbuffer.Bytebuffer that is transmitted over
|
|
/// GRPC
|
|
/// - Parameter byteBuffer: Flatbuffer ByteBuffer object
|
|
public init(byteBuffer: ByteBuffer) {
|
|
buffer = byteBuffer
|
|
}
|
|
|
|
/// Initializes the message by copying the buffer to the message to be sent.
|
|
/// from the builder
|
|
/// - Parameter builder: FlatbufferBuilder that has the bytes created in
|
|
/// - Note: Use `builder.finish(offset)` before passing the builder without prefixing anything to it
|
|
public init(builder: inout FlatBufferBuilder) {
|
|
buffer = builder.sizedBuffer
|
|
builder.clear()
|
|
}
|
|
}
|