ankur22

package main

import (
	"log"
)

type logger struct{}

func (l *logger) do(in string) {
	log.Println(in)

ankur22

type doer interface {
	do(string)
}

type validator interface {
	validate(string) bool
	do(int)
}

type doerAndValidator interface {

ankur22

type doer interface {
	do(string)
}

type validator interface {
	validate(string) bool
	do(string)
}

type doerAndValidator interface {

ankur22

package main

import (
	"log"
)

type doer interface {
	do(string)
}

ankur22

package main

import (
	"fmt"
	"log"
	"net/http"

	"github.com/cenkalti/backoff/v4"
)

ankur22

timeout := time.Millisecond * 500
timeoutTimer := time.NewTimer(timeout)
defer timeoutTimer.Stop()
eg.Go(func() error {
	for {
		select {
		case <-done():
			fmt.Println("Sender: Context closed")
			return ctx.Err()
		case <-timeoutTimer.C:

ankur22

done := ctx.Done()
eg, ctx := errgroup.WithContext(ctx)
eg.Go(func() error {
	defer close(lines)
	for {
		if !scanner.Scan() {
			fmt.Println("Reader: Completed")
			break
		}
		lines <- scanner.Text()

ankur22

eg.Go(func() error {
	for l := range lines {
		select {
		case <-ctx.Done():
			fmt.Println("Sender: Context closed")
			return ctx.Err()
		default:
			fmt.Printf("Sender: Sending %s to remote database\n", l)
		}
	}

ankur22

eg.Go(func() error {
	defer close(lines)
	for {
		if !scanner.Scan() {
			fmt.Println("Reader: Completed")
			break
		}
		lines <- scanner.Text()
		time.Sleep(time.Second) // To fake the slow writing to the lines channel

ankur22

eg, ctx := errgroup.WithContext(ctx)
eg.Go(func() error {
	defer close(lines)
	for {
		if !scanner.Scan() {
			fmt.Println("Reader: Completed")
			break
		}
		lines <- scanner.Text()