luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed unit tests

Browse source
This commit is contained in:
Xavi Ramirez 2017-08-07 00:54:29 +00:00
parent 4809cdb4e6
commit 5c373fa7d8
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
batchconsumer/writer_test.go
View file

@ -124,9 +124,8 @@ func (m *mockCheckpointer) wait() error {
func (m *mockCheckpointer) Shutdown() { func (m *mockCheckpointer) Shutdown() {
m.shutdown <- struct{}{} m.shutdown <- struct{}{}
} }
func (m *mockCheckpointer) Checkpoint(pair kcl.SequencePair, retry int) error { func (m *mockCheckpointer) Checkpoint(pair kcl.SequencePair) {
m.checkpoint <- pair.Sequence.String() m.checkpoint <- pair.Sequence.String()
return nil
} }
func encode(str string) string { func encode(str string) string {