package io.muoncore.protocol.reactivestream.messages;

import java.util.HashMap;
import java.util.Map;

public class ReactiveStreamSubscriptionRequest {

    private String streamName;
    private Map<String, Object> args = new HashMap<>();

    public ReactiveStreamSubscriptionRequest(String streamName) {
        this.streamName = streamName;
    }

    public String getStreamName() {
        return streamName;
    }

    public void arg(String name, String value) {
        args.put(name, value);
    }

    public Map<String, Object> getArgs() {
        return args;
    }


}

@@ -48,16 +48,51 @@
 sages;%0A%0A
+import io.muoncore.protocol.Auth;%0A%0A
 import j
@@ -184,16 +184,35 @@
 st %7B%0A%0A  
+private Auth auth;%0A
   privat
@@ -232,18 +232,16 @@
 amName;%0A
-  
   privat
@@ -287,18 +287,16 @@
 p%3C%3E();%0A%0A
-  
   public
@@ -351,59 +351,235 @@
 Name
-) %7B%0A        this.streamName = streamName;%0A    %7D%0A%0A  
+, Auth auth) %7B%0A    this.auth = auth;%0A    this.streamName = streamName;%0A  %7D%0A%0A  public ReactiveStreamSubscriptionRequest(String streamName) %7B%0A    this.streamName = streamName;%0A  %7D%0A%0A  public Auth getAuth() %7B%0A    return auth;%0A  %7D%0A%0A
   pu
@@ -608,28 +608,24 @@
 ame() %7B%0A    
-  
-  
 return strea
@@ -631,25 +631,21 @@
 amName;%0A
-  
   %7D%0A%0A
-  
   public
@@ -687,20 +687,16 @@
 ) %7B%0A    
- 
-   
 args.put
@@ -714,17 +714,13 @@
 e);%0A
-  
   %7D%0A%0A
-  
   pu
@@ -756,20 +756,16 @@
 rgs() %7B%0A
-    
     retu
@@ -773,18 +773,16 @@
 n args;%0A
-  
   %7D%0A%0A%0A%7D%0A

add space for auth in sub request