src/client/pfs.go
func (c APIClient) GetObjectReader(hash string) (io.ReadCloser, error) {
	ctx, cancel := context.WithCancel(c.Ctx())
	getObjectClient, err := c.ObjectAPIClient.GetObject(
		ctx,
		&pfs.Object{Hash: hash},
	)
	if err != nil {
		return nil, grpcutil.ScrubGRPC(err)
	}
	return grpcutil.NewStreamingBytesReader(getObjectClient, cancel), nil
}
func (c APIClient) GetObjectReader(hash string) (io.ReadCloser, error) {
	ctx, cancel := context.WithCancel(c.Ctx())
	getObjectClient, err := c.ObjectAPIClient.GetObject(
		ctx,
		&pfs.Object{Hash: hash},
	)
	if err != nil {
		return nil, grpcutil.ScrubGRPC(err)
	}
	return grpcutil.NewStreamingBytesReader(getObjectClient, cancel), nil
}
func ( c APIClient ) GetObjectReader ( hash string ) ( io . ReadCloser , error ) { ctx , cancel := context . WithCancel ( c . Ctx ( ) ) getObjectClient , err := c . ObjectAPIClient . GetObject ( ctx , & pfs . Object { Hash : hash } , ) if err != nil { return nil , grpcutil . ScrubGRPC ( err ) } return grpcutil . NewStreamingBytesReader ( getObjectClient , cancel ) , nil }
// GetObjectReader returns a reader for an object in object store by hash.
GetObjectReader returns a reader for an object in object store by hash .