qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-22 02:14:40 -07:00
Code Releases Activity

netchan: make -1 unlimited, as advertised.

Browse Source 
R=adg
CC=golang-dev
https://golang.org/cl/2198042
This commit is contained in:
Rob Pike 2010-09-14 23:41:37 -07:00
parent 7f0ddd682a
commit 8d831de685
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/pkg/netchan/common.go
View File

@ -39,7 +39,7 @@ type header struct {
// Sent with a header once per channel from importer to exporter to report // Sent with a header once per channel from importer to exporter to report
// that it wants to bind to a channel with the specified direction for count // that it wants to bind to a channel with the specified direction for count
// messages. If count is zero, it means unlimited. // messages. If count is -1, it means unlimited.
type request struct { type request struct {
count int64 count int64
dir Dir dir Dir

2
src/pkg/netchan/import.go
View File

@ -114,7 +114,7 @@ func (imp *Importer) run() {
// Import imports a channel of the given type and specified direction. // Import imports a channel of the given type and specified direction.
// It is equivalent to ImportNValues with a count of -1, meaning unbounded. // It is equivalent to ImportNValues with a count of -1, meaning unbounded.
func (imp *Importer) Import(name string, chT interface{}, dir Dir) os.Error { func (imp *Importer) Import(name string, chT interface{}, dir Dir) os.Error {
return imp.ImportNValues(name, chT, dir, 0) return imp.ImportNValues(name, chT, dir, -1)
} }
// ImportNValues imports a channel of the given type and specified direction // ImportNValues imports a channel of the given type and specified direction