Streams v2 (#23)

.travis.yml

@@ -2,23 +2,21 @@ sudo: false
 
 language: go
 go:
-  - "1.10"
+  - "1.11"
+  - "1.x"
+env:
+  - GO111MODULE=on
 
 before_install:
-  - curl -L -s https://github.com/golang/dep/releases/download/v0.4.1/dep-linux-amd64 -o $GOPATH/bin/dep
-  - chmod +x $GOPATH/bin/dep
   - go get -u golang.org/x/lint/golint
-  - go get github.com/mattn/goveralls
   - go get golang.org/x/tools/cmd/cover
-
-install:
-  - dep ensure
+  - go get github.com/mattn/goveralls
 
 script:
-#  - golint $(go list ./... | grep -v /vendor/)
+#  - golint ./...
   - go vet ./...
-  - go test -cover ./...
-  - $HOME/gopath/bin/goveralls -service=travis-ci -ignore=example/*
+  - go test -covermode=count -coverprofile=profile.cov ./...
+  - goveralls -coverprofile=profile.cov -service=travis-ci -ignore=example/*
 
 notifications:
   email: false

README.md

@@ -3,6 +3,7 @@
 [![Go Report Card](https://goreportcard.com/badge/github.com/msales/streams)](https://goreportcard.com/report/github.com/msales/streams)
 [![Build Status](https://travis-ci.org/msales/streams.svg?branch=master)](https://travis-ci.org/msales/streams)
 [![Coverage Status](https://coveralls.io/repos/github/msales/streams/badge.svg?branch=master)](https://coveralls.io/github/msales/streams?branch=master)
+[![GoDoc](https://godoc.org/github.com/msales/streams?status.svg)](https://godoc.org/github.com/msales/streams)
 [![GitHub release](https://img.shields.io/github/release/msales/streams.svg)](https://github.com/msales/streams/releases)
 [![GitHub license](https://img.shields.io/badge/license-MIT-blue.svg)](https://raw.githubusercontent.com/msales/streams/master/LICENSE)
 

cache/sink.go

@@ -3,8 +3,8 @@ package cache
 import (
 	"time"
 
-	"github.com/msales/pkg/cache"
-	"github.com/msales/streams"
+	"github.com/msales/pkg/v3/cache"
+	"github.com/msales/streams/v2"
 )
 
 // Sink represents a Cache streams sink.
@@ -48,7 +48,7 @@ func (p *Sink) Process(msg *streams.Message) error {
 		return p.pipe.Commit(msg)
 	}
 
-	return nil
+	return p.pipe.Mark(msg)
 }
 
 // Close closes the processor.