diff options
| author | Rob Pike <r@golang.org> | 2010-09-14 23:41:37 -0700 |
|---|---|---|
| committer | Rob Pike <r@golang.org> | 2010-09-14 23:41:37 -0700 |
| commit | bd1458e0249ef167726fa28798016036c4ec7280 (patch) | |
| tree | ed1cf37ba3a5976e6a4880263d542352311904a9 | |
| parent | f22347509c3621fb24f1dd7fc3f0e8ce7967582f (diff) | |
| download | go-bd1458e0249ef167726fa28798016036c4ec7280.tar.gz | |
netchan: make -1 unlimited, as advertised.
R=adg
CC=golang-dev
http://codereview.appspot.com/2198042
| -rw-r--r-- | src/pkg/netchan/common.go | 2 | ||||
| -rw-r--r-- | src/pkg/netchan/import.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/pkg/netchan/common.go b/src/pkg/netchan/common.go index c5fd5698c..010b957ac 100644 --- a/src/pkg/netchan/common.go +++ b/src/pkg/netchan/common.go @@ -39,7 +39,7 @@ type header struct { // 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 -// messages. If count is zero, it means unlimited. +// messages. If count is -1, it means unlimited. type request struct { count int64 dir Dir diff --git a/src/pkg/netchan/import.go b/src/pkg/netchan/import.go index 6a065543b..77ec24d77 100644 --- a/src/pkg/netchan/import.go +++ b/src/pkg/netchan/import.go @@ -114,7 +114,7 @@ func (imp *Importer) run() { // Import imports a channel of the given type and specified direction. // It is equivalent to ImportNValues with a count of -1, meaning unbounded. 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 |