Skip to content

Commit

Permalink
Minor types improvement for mix operator [ci fast]
Browse files Browse the repository at this point in the history
Signed-off-by: Paolo Di Tommaso <[email protected]>
  • Loading branch information
pditommaso committed Oct 30, 2023
1 parent 35a4424 commit 91c1ab1
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,16 +35,16 @@ import nextflow.Channel
class MixOp {

private DataflowReadChannel source
private DataflowReadChannel[] others
private List<DataflowReadChannel> others

MixOp(DataflowReadChannel source, DataflowReadChannel other) {
this.source = source
this.others = [other]
this.others = List.of(other)
}

MixOp(DataflowReadChannel source, DataflowReadChannel[] others) {
this.source = source
this.others = others
this.others = others.toList()
}

DataflowWriteChannel apply() {
Expand All @@ -60,7 +60,7 @@ class MixOp {
subscribeImpl(it, handlers)
}

def allSources = [source]
final allSources = [source]
allSources.addAll(others)
return target
}
Expand Down

0 comments on commit 91c1ab1

Please sign in to comment.