stream support, tests (#10)

Makefile

@@ -9,3 +9,6 @@ rerun-install:
 
 rerun:
 	rerun -watch . -ignore out -run sh -c 'go run . -s _examples/e1.ridl'
+
+test:
+	go test -v -coverprofile=coverage.txt -covermode=atomic ./...

_examples/e1.ridl

@@ -76,3 +76,10 @@ service ExampleService # oof
 @public
    - GetUser   (   header   :    map  <   string   ,   string   >   ,   userID   :    uint64   )   =>   (  code  :   uint32   ,   user  :   User  )
     - FindUser(s :SearchFilter) => (name: string, user: User) ###! last
+
+    -    stream    Re cv   (req  :   string   )
+
+  -     stream    Sen  d()    =>    (resp: string)
+
+  -stream                        Se ndAndRecv(req: string) => stream (resp: string)
+  -streamSe ndAndRecv(req: string) => stream (resp: string)

formatter/processor.go

@@ -184,7 +184,15 @@ func (f *form) formatLine(line string) (string, error) {
 			s, c := parseAndDivideInlineComment(line)
 			parts := strings.Split(s, "=>")
 			p1 := strings.TrimSpace(parts[0])
-			methodName := strings.TrimPrefix(strings.TrimSpace(strings.ReplaceAll(strings.Split(p1, "(")[0], " ", "")), "-")
+
+			methodName := strings.TrimSpace(strings.TrimPrefix(strings.TrimSpace(strings.Split(p1, "(")[0]), "-"))
+			methodName, isStreamInput := strings.CutPrefix(methodName, "stream ")
+			methodName = removeSpaces(methodName)
+
+			if isStreamInput {
+				methodName = "stream " + methodName
+			}
+
 			inArgs, err := formatMethodArguments(p1)
 			if err != nil {
 				return line, err

main_test.go

@@ -162,6 +162,13 @@ service ExampleService # oof
    - GetUser   (   header   :    map  <   string   ,   string   >   ,   userID   :    uint64   )   =>   (  code  :   uint32   ,   user  :   User  )
     - FindUser(s :SearchFilter) => (name: string, user: User) ###! last
 
+    -    stream    Re cv   (req  :   string   )
+
+
+  -     stream    Sen  d()    =>    (resp: string)
+
+  -stream                        Se ndAndRecv(req: string) => stream (resp: string)
+  -streamSe ndAndRecv(req: string) =>          stream (resp: string)
 
 
 
@@ -246,4 +253,11 @@ service ExampleService # oof
     @public
   - GetUser(header: map<string,string>, userID: uint64) => (code: uint32, user: User)
   - FindUser(s: SearchFilter) => (name: string, user: User) ###! last
+
+  - stream Recv(req: string)
+
+  - stream Send() => (resp: string)
+
+  - stream SendAndRecv(req: string) => stream (resp: string)
+  - streamSendAndRecv(req: string) => stream (resp: string)
 `