CanerPatir

suspend fun someSuspendableOperation(): String {
    delay(1000L) // representation of IO operation like going to DB
    return "hello"
}

CanerPatir

#!/bin/zsh

for i in */.git; 
do ( echo $i; cd $i/..; git pull; git fetch -p && for branch in `git branch -vv | grep ': gone]' | awk '{print $1}'`; do git branch -D $branch; done );
done

CanerPatir

public class MyTask : ScheduleTask
{
        public MyTask(IServiceScopeFactory serviceScopeFactory) : base(serviceScopeFactory)
        {
        }
 
        protected override string CronExpression => "*/10 * * * *";

        public override Task Execute(IServiceProvider serviceProvider)
        {

CanerPatir

@FunctionalInterface
public interface PipelineStep<I, O, Ctx> {
    static <I, O, Ctx> PipelineStep<I, O, Ctx> of(PipelineStep<I, O, Ctx> source) {
        return source;
    }

    O execute(I value, Ctx context) throws Exception;

    default <R> PipelineStep<I, R, Ctx> pipe(PipelineStep<O, R, Ctx> next) {

CanerPatir

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;

namespace TDFDemo
{
    class Program
    {