1 files changed, 69 insertions, 0 deletions
diff --git a/driver/token_stream.go b/driver/token_stream.go
new file mode 100644
index 0000000..feb86ae
--- /dev/null
+++ b/driver/token_stream.go
@@ -0,0 +1,69 @@
+package driver
+
+import (
+	"io"
+
+	mldriver "github.com/nihei9/maleeni/driver"
+	"github.com/nihei9/vartan/spec"
+)
+
+type token struct {
+	terminalID int
+	skip       bool
+	tok        *mldriver.Token
+}
+
+func (t *token) TerminalID() int {
+	return t.terminalID
+}
+
+func (t *token) Lexeme() []byte {
+	return t.tok.Lexeme
+}
+
+func (t *token) EOF() bool {
+	return t.tok.EOF
+}
+
+func (t *token) Invalid() bool {
+	return t.tok.Invalid
+}
+
+func (t *token) Skip() bool {
+	return t.skip
+}
+
+func (t *token) Position() (int, int) {
+	return t.tok.Row, t.tok.Col
+}
+
+type tokenStream struct {
+	lex            *mldriver.Lexer
+	kindToTerminal []int
+	skip           []int
+}
+
+func NewTokenStream(g *spec.CompiledGrammar, src io.Reader) (TokenStream, error) {
+	lex, err := mldriver.NewLexer(mldriver.NewLexSpec(g.LexicalSpecification.Maleeni.Spec), src)
+	if err != nil {
+		return nil, err
+	}
+
+	return &tokenStream{
+		lex:            lex,
+		kindToTerminal: g.LexicalSpecification.Maleeni.KindToTerminal,
+		skip:           g.LexicalSpecification.Maleeni.Skip,
+	}, nil
+}
+
+func (l *tokenStream) Next() (Token, error) {
+	tok, err := l.lex.Next()
+	if err != nil {
+		return nil, err
+	}
+	return &token{
+		terminalID: l.kindToTerminal[tok.KindID],
+		skip:       l.skip[tok.KindID] > 0,
+		tok:        tok,
+	}, nil
+}