lang: funcs: structs: Fix typos
This commit is contained in:
@@ -147,7 +147,7 @@ func (obj *ChannelBasedSinkFunc) Stream(ctx context.Context) error {
|
||||
|
||||
// Call this function with the input args and return the value if it is possible
|
||||
// to do so at this time.
|
||||
// XXX: Is is correct to implement this here for this particular function?
|
||||
// XXX: Is it correct to implement this here for this particular function?
|
||||
func (obj *ChannelBasedSinkFunc) Call(ctx context.Context, args []types.Value) (types.Value, error) {
|
||||
if len(args) != 1 {
|
||||
return nil, fmt.Errorf("programming error, can't find edge")
|
||||
|
||||
@@ -114,7 +114,7 @@ func (obj *ChannelBasedSourceFunc) Stream(ctx context.Context) error {
|
||||
}
|
||||
}
|
||||
|
||||
// XXX: Is is correct to implement this here for this particular function?
|
||||
// XXX: Is it correct to implement this here for this particular function?
|
||||
// XXX: tricky since this really receives input from a secret channel...
|
||||
// XXX: ADD A MUTEX AROUND READING obj.last ???
|
||||
//func (obj *ChannelBasedSourceFunc) Call(ctx context.Context, args []types.Value) (types.Value, error) {
|
||||
|
||||
@@ -148,7 +148,7 @@ func (obj *IfFunc) Stream(ctx context.Context) error {
|
||||
|
||||
// Call this function with the input args and return the value if it is possible
|
||||
// to do so at this time.
|
||||
// XXX: Is is correct to implement this here for this particular function?
|
||||
// XXX: Is it correct to implement this here for this particular function?
|
||||
func (obj *IfFunc) Call(ctx context.Context, args []types.Value) (types.Value, error) {
|
||||
if obj.Info() == nil {
|
||||
return nil, fmt.Errorf("info is empty")
|
||||
|
||||
Reference in New Issue
Block a user