Merge branch 'release/0.2.2'

CHANGELOG.md

@@ -5,6 +5,10 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 
 ## [Unreleased]
 
+## [0.2.2] - 2020-10-29
+### Added
+* Add --s-to-c-buf-size flag to client
+
 ## [0.2.1] - 2020-10-18
 ### Added
 * Add --header flag to specify HTTP header
@@ -22,6 +26,7 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 ### Added
 * Initial release
 
-[Unreleased]: https://github.com/nwtgck/go-piping-tunnel/compare/v0.2.1...HEAD
+[Unreleased]: https://github.com/nwtgck/go-piping-tunnel/compare/v0.2.2...HEAD
+[0.2.2]: https://github.com/nwtgck/go-piping-tunnel/compare/v0.2.1...v0.2.2
 [0.2.1]: https://github.com/nwtgck/go-piping-tunnel/compare/v0.2.0...v0.2.1
 [0.2.0]: https://github.com/nwtgck/go-piping-tunnel/compare/v0.1.0...v0.2.0

cmd/client.go

@@ -15,10 +15,12 @@ import (
 )
 
 var clientHostPort int
+var clientServerToClientBuffSize uint
 
 func init() {
 	RootCmd.AddCommand(clientCmd)
 	clientCmd.Flags().IntVarP(&clientHostPort, "port", "p", 0, "TCP port of client host")
+	clientCmd.Flags().UintVarP(&clientServerToClientBuffSize, "s-to-c-buf-size", "", 16, "Buffer size of server-to-client")
 }
 
 var clientCmd = &cobra.Command{
@@ -115,7 +117,8 @@ var clientCmd = &cobra.Command{
 		if progress != nil {
 			writer = io.MultiWriter(conn, progress)
 		}
-		_, err = io.Copy(writer, res.Body)
+		var buf = make([]byte, clientServerToClientBuffSize)
+		_, err = io.CopyBuffer(writer, res.Body, buf)
 		fmt.Println()
 		if err != nil {
 			return err

version/version.go

@@ -1,3 +1,3 @@
 package version
 
-const Version = "0.2.1"
+const Version = "0.2.2"