fix(flatmap): flatMap shouldn't throw when the input size is smaller than concurrent

fix(flatmap): flatMap shouldn't throw when the input size is smaller than concurrent #47