lexer.go

package lexer
import (
  "fmt"
  "strings"
  "pizzascript/token"
  "github.com/reactivex/rxgo/v2"
)

type Lexer struct {
  input       string
  observable  rxgo.Observable
}

func New(input string) *Lexer {
  observable := rxgo.Just(input)().FlatMap(func(i rxgo.Item) rxgo.Observable {
    splitted := strings.Split(i.V.(string), "")
    return rxgo.Just(splitted)()
  })
  l := &Lexer{input: input, observable: observable}
  return l
}