Myriad/fix make stream (#177)

* Add make_stream argument to be passed * empty Co-authored-by: Nael Alolwani <naelalolwani@gmail.com>
deriv-com · Jul 6, 2021 · f0e2676 · f0e2676
1 parent d1f47c5
commit f0e2676
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/Myriad/RPC/Implementation/Redis.pm b/lib/Myriad/RPC/Implementation/Redis.pm
@@ -83,7 +83,7 @@ async method stop () {
 
 async method create_group ($rpc) {
     unless ($rpc->{group}) {
-        await $self->redis->create_group($rpc->{stream}, $self->group_name);
+        await $self->redis->create_group($rpc->{stream}, $self->group_name, '$', 1);
         $rpc->{group} = 1;
     }
 }