mirror of
https://github.com/ipfs/kubo.git
synced 2025-06-29 09:34:03 +08:00
fix legacy command tests
License: MIT Signed-off-by: Steven Allen <steven@stebalien.com>
This commit is contained in:
@ -69,12 +69,11 @@ func TestNewCommand(t *testing.T) {
|
||||
|
||||
// test calling "test" command
|
||||
testCmd := root.Subcommands["test"]
|
||||
enc := testCmd.Encoders[oldcmds.Text]
|
||||
if enc == nil {
|
||||
t.Fatal("got nil encoder")
|
||||
}
|
||||
|
||||
re := cmds.NewWriterResponseEmitter(WriteNopCloser{buf}, req, enc)
|
||||
re, err := cmds.NewWriterResponseEmitter(WriteNopCloser{buf}, req)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
var env oldcmds.Context
|
||||
|
||||
@ -122,8 +121,14 @@ func TestPipePair(t *testing.T) {
|
||||
}
|
||||
|
||||
r, w := io.Pipe()
|
||||
re := cmds.NewWriterResponseEmitter(w, req, cmds.Encoders[cmds.JSON])
|
||||
res := cmds.NewReaderResponse(r, cmds.JSON, req)
|
||||
re, err := cmds.NewWriterResponseEmitter(w, req)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
res, err := cmds.NewReaderResponse(r, req)
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
wait := make(chan interface{})
|
||||
|
||||
|
Reference in New Issue
Block a user