Method Commit

Source/Libraries/Bridge/Source/RemoteClientBridge.cpp:250–280

}

void RemoteClientBridge::Commit() {
    // Get number of streams
    uint32_t streamCount;
    storage.ConsumeStreams(&streamCount, nullptr);

    // Get all streams
    streamCache.resize(streamCount);
    storage.ConsumeStreams(&streamCount, streamCache.data());

    // Push all streams
    for (uint32_t i = 0; i < streamCount; i++) {
        const MessageStream &stream = streamCache[i];

        // Setup protocol header
        MessageStreamHeaderProtocol protocol;
        protocol.schema = stream.GetSchema();
        protocol.versionID = stream.GetVersionID();
        protocol.size = stream.GetByteSize();

        // Send header and stream data (sync)
        client->WriteAsync(&protocol, sizeof(protocol));
        client->WriteAsync(stream.GetDataBegin(), protocol.size);

        // Tracking
        info.bytesWritten += sizeof(protocol);
        info.bytesWritten += protocol.size;
    }

    // Commit all inbound streams
    memoryBridge.Commit();
}