Implement some flow blocks

README.md

@@ -114,6 +114,7 @@ The built-in blocks provided by Protoflow are listed below:
 |:------------------|:-------------------------------------------------------------------------------------------------------------------------------|
 | [`Buffer`]        | Stores all messages it receives.                                                                                               |
 | [`ConcatStrings`] | Concatenates the received string messages, with an optional delimiter string inserted between each message.                    |
+| [`Concat`]        | Merges multiple input message streams into a single output stream.                                                             |
 | [`Const`]         | Sends a constant value.                                                                                                        |
 | [`Count`]         | Counts the number of messages it receives, while optionally passing them through.                                              |
 | [`Decode`]        | Decodes messages from a byte stream.                                                                                           |
@@ -127,12 +128,16 @@ The built-in blocks provided by Protoflow are listed below:
 | [`EncodeHex`]     | Encodes a byte stream into hexadecimal form.                                                                                   |
 | [`EncodeJSON`]    | Encodes messages into JSON format.                                                                                             |
 | [`Hash`]          | Computes the cryptographic hash of a byte stream.                                                                              |
+| [`Merge`]         | Combines multiple input message streams into a single output stream by interleaving messages as they arrive.                   |
 | [`Random`]        | Generates and sends a random value.                                                                                            |
 | [`ReadDir`]       | Reads file names from a file system directory.                                                                                 |
 | [`ReadEnv`]       | Reads the value of an environment variable.                                                                                    |
 | [`ReadFile`]      | Reads bytes from the contents of a file.                                                                                       |
 | [`ReadSocket`]    | Reads bytes from a TCP socket.                                                                                                 |
 | [`ReadStdin`]     | Reads bytes from standard input (aka stdin).                                                                                   |
+| [`Replicate`]     | Duplicates a single input message stream into multiple identical output streams.                                               |
+| [`Sort`]          | Sorts a single input message stream in ascending order.                                                                        |
+| [`Split`]         | Divides a single input message stream into multiple output streams using a round-robin approach.                               |
 | [`SplitString`]   | Splits the received input message, with an optional delimiter string parameter.                                                |
 | [`WriteFile`]     | Writes or appends bytes to the contents of a file.                                                                             |
 | [`WriteSocket`]   | Writes bytes to a TCP socket                                                                                                   |
@@ -159,6 +164,32 @@ block-beta
 protoflow execute Buffer
 ```
 
+#### [`Concat`]
+
+Concatenates multiple input message streams into a single output stream.
+
+```mermaid
+block-beta
+    columns 7
+    space:1 Source1 space:5
+    space:3 Concat space:1 Sink space:1
+    space:1 Source2 space:5
+    Source1-- "input" -->Concat
+    Source2-- "input" -->Concat
+    Concat-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Concat block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink hidden
+```
+
+```bash
+protoflow execute Concat
+```
+
 #### [`ConcatStrings`]
 
 A block for concatenating all string messages it receives, with an optional delimiter string inserted between each message
@@ -483,6 +514,32 @@ block-beta
 protoflow execute Hash algorithm=blake3
 ```
 
+#### [`Merge`]
+
+Combines multiple input message streams into a single output stream by interleaving messages as they arrive.
+
+```mermaid
+block-beta
+    columns 7
+    space:1 Source1 space:5
+    space:3 Merge space:1 Sink space:1
+    space:1 Source2 space:5
+    Source1-- "input" -->Merge
+    Source2-- "input" -->Merge
+    Merge-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Merge block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink hidden
+```
+
+```bash
+protoflow execute Merge
+```
+
 #### [`Random`]
 
 A block for generating and sending a random value.
@@ -618,6 +675,83 @@ block-beta
 protoflow execute ReadStdin < input.txt
 ```
 
+#### [`Replicate`]
+
+Duplicates a single input message stream into multiple identical output streams.
+
+```mermaid
+block-beta
+    columns 7
+    space:5 Sink1 space:1
+    space:1 Source space:1 Replicate space:3
+    space:5 Sink2 space:1
+
+    Source-- "input" -->Replicate
+    Replicate-- "output" -->Sink1
+    Replicate-- "output" -->Sink2
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Replicate block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink1 hidden
+    class Sink2 hidden
+```
+
+```bash
+protoflow execute Replicate
+```
+
+#### [`Sort`]
+
+Sorts a single input message stream in ascending order.
+
+```mermaid
+block-beta
+    columns 7
+    Source space:2 Sort space:2 Sink
+    Source-- "input" -->Sort
+    Sort-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Sort block
+    class Source hidden
+    class Sink hidden
+    class Sink2 hidden
+```
+
+```bash
+protoflow execute Sort
+```
+
+#### [`Split`]
+
+Divides a single input message stream into multiple output streams using a round-robin approach.
+
+```mermaid
+block-beta
+    columns 7
+    space:5 Sink1 space:1
+    space:1 Source space:1 Split space:3
+    space:5 Sink2 space:1
+    Source-- "input" -->Split
+    Split-- "output_1" -->Sink1
+    Split-- "output_2" -->Sink2
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Split block
+    class Source hidden
+    class Sink1 hidden
+    class Sink2 hidden
+```
+
+```bash
+protoflow execute Split
+```
+
 #### [`SplitString`]
 
 A block that splits the received input message, with an optional delimiter string parameter
@@ -795,6 +929,7 @@ To add a new block type implementation, make sure to examine and amend:
 [`examples`]: lib/protoflow/examples
 
 [`Buffer`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Buffer.html
+[`Concat`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Concat.html
 [`ConcatStrings`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ConcatStrings.html
 [`Const`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Const.html
 [`Count`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Count.html
@@ -809,12 +944,16 @@ To add a new block type implementation, make sure to examine and amend:
 [`EncodeHex`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.EncodeHex.html
 [`EncodeJSON`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.EncodeJson.html
 [`Hash`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Hash.html
+[`Merge`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Merge.html
 [`Random`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Random.html
 [`ReadDir`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ReadDir.html
 [`ReadEnv`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ReadEnv.html
 [`ReadFile`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ReadFile.html
 [`ReadSocket`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ReadSocket.html
 [`ReadStdin`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.ReadStdin.html
+[`Replicate`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Replicate.html
+[`Sort`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Sort.html
+[`Split`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.Split.html
 [`SplitString`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.SplitString.html
 [`WriteFile`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.WriteFile.html
 [`WriteSocket`]: https://docs.rs/protoflow-blocks/latest/protoflow_blocks/struct.WriteSocket.html

lib/protoflow-blocks/doc/flow/concat.mmd

@@ -0,0 +1,15 @@
+block-beta
+    columns 7
+    space:1 Source1 space:5
+    space:3 Concat space:1 Sink space:1
+    space:1 Source2 space:5
+    Source1-- "input" -->Concat
+    Source2-- "input" -->Concat
+    Concat-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Concat block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink hidden

lib/protoflow-blocks/doc/flow/concat.seq.mmd

@@ -0,0 +1,28 @@
+sequenceDiagram
+    autonumber
+    participant BlockA as Another block
+    participant BlockA2 as Another block
+    participant Concat.input as Concat.input port
+    participant Concat.input2 as Concat.input port
+    participant Concat as Concat block
+    participant Concat.output as Concat.output port
+    participant BlockB as Another block
+
+    BlockA-->>Concat: Connect
+    BlockA2-->>Concat: Connect
+    Concat-->>BlockB: Connect
+
+    loop Concat process
+        BlockA->>Concat: Message
+        Concat->>Concat: Store message
+        BlockA2->>Concat: Message
+        Concat->>Concat: Store message
+    end
+    Concat->>Concat: Concat messages
+    Concat->>BlockB: Message
+    BlockA-->>Concat: Disconnect
+    BlockA2-->>Concat: Disconnect
+    Concat-->>Concat.input: Close
+    Concat-->>Concat.input2: Close
+    Concat-->>Concat.output: Close
+    Concat-->>BlockB: Disconnect

lib/protoflow-blocks/doc/flow/merge.mmd

@@ -0,0 +1,15 @@
+block-beta
+    columns 7
+    space:1 Source1 space:5
+    space:3 Merge space:1 Sink space:1
+    space:1 Source2 space:5
+    Source1-- "input" -->Merge
+    Source2-- "input" -->Merge
+    Merge-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Merge block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink hidden

lib/protoflow-blocks/doc/flow/merge.seq.mmd

@@ -0,0 +1,26 @@
+sequenceDiagram
+    autonumber
+    participant BlockA as Another block
+    participant BlockA2 as Another block
+    participant Merge.input as Merge.input port
+    participant Merge.input2 as Merge.input port
+    participant Merge as Merge block
+    participant Merge.output as Merge.output port
+    participant BlockB as Another block
+
+    BlockA-->>Merge: Connect
+    BlockA2-->>Merge: Connect
+    Merge-->>BlockB: Connect
+
+    loop Merge process
+        BlockA->>Merge: Message
+        Merge->>BlockB: Message
+        BlockA2->>Merge: Message
+        Merge->>BlockB: Message
+    end
+    BlockA-->>Merge: Disconnect
+    BlockA2-->>Merge: Disconnect
+    Merge-->>Merge.input: Close
+    Merge-->>Merge.input2: Close
+    Merge-->>Merge.output: Close
+    Merge-->>BlockB: Disconnect

lib/protoflow-blocks/doc/flow/replicate.mmd

@@ -0,0 +1,17 @@
+block-beta
+    columns 7
+    space:5 Sink1 space:1
+    space:1 Source space:1 Replicate space:3
+    space:5 Sink2 space:1
+
+    Source-- "input" -->Replicate
+    Replicate-- "output" -->Sink1
+    Replicate-- "output" -->Sink2
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Replicate block
+    class Source1 hidden
+    class Source2 hidden
+    class Sink1 hidden
+    class Sink2 hidden

lib/protoflow-blocks/doc/flow/replicate.seq.mmd

@@ -0,0 +1,27 @@
+sequenceDiagram
+    autonumber
+    participant BlockA as Another block
+    participant Replicate.input as Replicate.input port
+    participant Replicate as Replicate block
+    participant Replicate.output_1 as Replicate.output port
+    participant BlockB as Another block
+    participant Replicate.output_2 as Replicate.output port
+    participant BlockC as Another block
+
+    BlockA-->>Replicate: Connect
+    Replicate-->>BlockB: Connect
+    Replicate-->>BlockC: Connect
+
+    loop Replicate process
+        BlockA->>Replicate: Message
+        Replicate->>BlockB: Message
+        Replicate->>BlockC: Message
+
+    end
+
+    BlockA-->>Replicate: Disconnect
+    Replicate-->>Replicate.input: Close
+    Replicate-->>Replicate.output_1: Close
+    Replicate-->>BlockB: Disconnect
+    Replicate-->>Replicate.output_2: Close
+    Replicate-->>BlockC: Disconnect

lib/protoflow-blocks/doc/flow/sort.mmd

@@ -0,0 +1,11 @@
+block-beta
+    columns 7
+    Source space:2 Sort space:2 Sink
+    Source-- "input" -->Sort
+    Sort-- "output" -->Sink
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Sort block
+    class Source hidden
+    class Sink hidden

lib/protoflow-blocks/doc/flow/sort.seq.mmd

@@ -0,0 +1,22 @@
+sequenceDiagram
+    autonumber
+    participant BlockA as Another block
+    participant Sort.input as Sort.input port
+    participant Sort as Sort block
+    participant Sort.output as Sort.output port
+    participant BlockB as Another block
+
+    BlockA-->>Sort: Connect
+    Sort-->>BlockB: Connect
+
+    loop Sort process
+        BlockA->>Sort: Message
+        Sort->>Sort: Store message
+    end
+
+    Sort->>Sort: Sort messages
+    Sort->>BlockB: Message
+    BlockA-->>Sort: Disconnect
+    Sort-->>Sort.input: Close
+    Sort-->>Sort.output: Close
+    Sort-->>BlockB: Disconnect

lib/protoflow-blocks/doc/flow/split.mmd

@@ -0,0 +1,15 @@
+block-beta
+    columns 7
+    space:5 Sink1 space:1
+    space:1 Source space:1 Split space:3
+    space:5 Sink2 space:1
+    Source-- "input" -->Split
+    Split-- "output_1" -->Sink1
+    Split-- "output_2" -->Sink2
+
+    classDef block height:48px,padding:8px;
+    classDef hidden visibility:none;
+    class Split block
+    class Source hidden
+    class Sink1 hidden
+    class Sink2 hidden