Add byte/int8/int16 stream functions. Fix travis-ci svg url

Author: johnteee

README.md

@@ -3,7 +3,7 @@
 [![tag](https://img.shields.io/github/tag/TeaEntityLab/fpGo.svg)](https://github.com/TeaEntityLab/fpGo)
 [![Go Report Card](https://goreportcard.com/badge/github.com/TeaEntityLab/fpGo)](https://goreportcard.com/report/github.com/TeaEntityLab/fpGo)
 [![codecov](https://codecov.io/gh/TeaEntityLab/fpGo/branch/master/graph/badge.svg)](https://codecov.io/gh/TeaEntityLab/fpGo)
-[![Travis CI Build Status](https://api.travis-ci.org/TeaEntityLab/fpGo.svg?branch=master)](https://travis-ci.org/TeaEntityLab/fpGo)
+[![Travis CI Build Status](https://travis-ci.com/TeaEntityLab/fpGo.svg?branch=master)](https://travis-ci.org/TeaEntityLab/fpGo)
 [![GoDoc](https://godoc.org/github.com/TeaEntityLab/fpGo?status.svg)](https://godoc.org/github.com/TeaEntityLab/fpGo)
 
 [![license](https://img.shields.io/github/license/TeaEntityLab/fpGo.svg?style=social&label=License)](https://github.com/TeaEntityLab/fpGo)

cor_test.go

@@ -50,7 +50,7 @@ func TestCorYield(t *testing.T) {
 		v, _ = Maybe.Just(self.Yield()).ToInt()
 		actualInt = v + 1
 
-		v, _ = Maybe.Just(self.YieldFromIO(MonadIO.Just(1).ObserveOn(&Handler))).ToInt()
+		v, _ = Maybe.Just(self.YieldFromIO(MonadIO.Just(1).ObserveOn(Handler.GetDefault()))).ToInt()
 		logMessage(self, "s", 5)
 		actualInt += v
 		logMessage(self, "s", 6)
@@ -104,7 +104,9 @@ func TestCorDoNotation(t *testing.T) {
 		logMessage(self, "Do Notation", "v", v)
 		logMessage(self, "Do Notation", "result", result)
 
-		v, _ = Maybe.Just(self.YieldFromIO(MonadIO.Just(1).ObserveOn(&Handler))).ToInt()
+		h := Handler.New()
+		defer h.Close()
+		v, _ = Maybe.Just(self.YieldFromIO(MonadIO.Just(1).ObserveOn(h))).ToInt()
 		result += v
 
 		logMessage(self, "Do Notation", "result", result)

stream.go

@@ -53,6 +53,39 @@ func (streamSelf *StreamDef) FromArrayInt(old []int) *StreamDef {
 	return streamSelf.FromArray(new)
 }
 
+// FromArrayByte New Stream instance from an int8 array
+func (streamSelf *StreamDef) FromArrayByte(old []byte) *StreamDef {
+	new := make([]interface{}, len(old))
+	for i, v := range old {
+		var item interface{} = v
+		new[i] = item
+	}
+
+	return streamSelf.FromArray(new)
+}
+
+// FromArrayInt8 New Stream instance from an int8 array
+func (streamSelf *StreamDef) FromArrayInt8(old []int8) *StreamDef {
+	new := make([]interface{}, len(old))
+	for i, v := range old {
+		var item interface{} = v
+		new[i] = item
+	}
+
+	return streamSelf.FromArray(new)
+}
+
+// FromArrayInt16 New Stream instance from an int16 array
+func (streamSelf *StreamDef) FromArrayInt16(old []int16) *StreamDef {
+	new := make([]interface{}, len(old))
+	for i, v := range old {
+		var item interface{} = v
+		new[i] = item
+	}
+
+	return streamSelf.FromArray(new)
+}
+
 // FromArrayInt32 New Stream instance from an int32 array
 func (streamSelf *StreamDef) FromArrayInt32(old []int32) *StreamDef {
 	new := make([]interface{}, len(old))

stream_test.go

@@ -95,13 +95,55 @@ func TestFromArrayMapReduce(t *testing.T) {
 		tempString += Maybe.Just(v).ToMaybe().ToString()
 	}
 	assert.Equal(t, "14916", tempString)
+
+	s = Stream.FromArrayBool([]bool{true, false, true, false})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "truefalsetruefalse", tempString)
+
+	s = Stream.FromArrayByte([]byte{1, 2, 3, 4})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "1234", tempString)
+
+	s = Stream.FromArrayInt8([]int8{1, 2, 3, 4})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "1234", tempString)
+
+	s = Stream.FromArrayInt16([]int16{1, 2, 3, 4})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "1234", tempString)
+
+	s = Stream.FromArrayInt32([]int32{1, 2, 3, 4})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "1234", tempString)
+
+	s = Stream.FromArrayInt64([]int64{1, 2, 3, 4})
+	tempString = ""
+	for _, v := range s.ToArray() {
+		tempString += Maybe.Just(v).ToMaybe().ToString()
+	}
+	assert.Equal(t, "1234", tempString)
 }
 
 func TestFilter(t *testing.T) {
 	var s *StreamDef
 	var tempString string
 
-	s = Stream.FromArrayInt([]int{}).Append(1).Extend(Stream.FromArrayInt([]int{2, 3, 4})).Extend(Stream.FromArray([]interface{}{nil}))
+	s = Stream.FromArrayInt([]int{}).Append(1).Extend(Stream.FromArrayInt([]int{2, 3, 4})).Extend(Stream.FromArray([]interface{}{nil})).Extend(nil)
 	tempString = ""
 	for _, v := range s.ToArray() {
 		tempString += Maybe.Just(v).ToMaybe().ToString()