mirror of
https://github.com/duke-git/lancet.git
synced 2025-09-27 03:45:58 +08:00
224 lines
2.7 KiB
Go
224 lines
2.7 KiB
Go
package function
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
func ExampleAfter() {
|
|
fn := After(2, func() {
|
|
fmt.Println("test")
|
|
})
|
|
|
|
fn()
|
|
fn()
|
|
|
|
// Output:
|
|
// test
|
|
}
|
|
|
|
func ExampleBefore() {
|
|
fn := Before(2, func() {
|
|
fmt.Println("test")
|
|
})
|
|
|
|
fn()
|
|
fn()
|
|
fn()
|
|
fn()
|
|
|
|
// Output:
|
|
// test
|
|
// test
|
|
}
|
|
|
|
func ExampleCurryFn_New() {
|
|
add := func(a, b int) int {
|
|
return a + b
|
|
}
|
|
|
|
var addCurry CurryFn[int] = func(values ...int) int {
|
|
return add(values[0], values[1])
|
|
}
|
|
add1 := addCurry.New(1)
|
|
|
|
result := add1(2)
|
|
|
|
fmt.Println(result)
|
|
|
|
// Output:
|
|
// 3
|
|
}
|
|
|
|
func ExampleCompose() {
|
|
toUpper := func(strs ...string) string {
|
|
return strings.ToUpper(strs[0])
|
|
}
|
|
toLower := func(strs ...string) string {
|
|
return strings.ToLower(strs[0])
|
|
}
|
|
transform := Compose(toUpper, toLower)
|
|
|
|
result := transform("aBCde")
|
|
|
|
fmt.Println(result)
|
|
|
|
// Output:
|
|
// ABCDE
|
|
}
|
|
|
|
func ExampleDelay() {
|
|
var print = func(s string) {
|
|
fmt.Println(s)
|
|
}
|
|
|
|
Delay(2*time.Second, print, "hello")
|
|
|
|
// Output:
|
|
// hello
|
|
}
|
|
|
|
func ExampleDebounce() {
|
|
callCount := 0
|
|
fn := func() {
|
|
callCount++
|
|
}
|
|
|
|
debouncedFn, _ := Debounce(fn, 500*time.Millisecond)
|
|
|
|
for i := 0; i < 10; i++ {
|
|
debouncedFn()
|
|
time.Sleep(50 * time.Millisecond)
|
|
}
|
|
|
|
time.Sleep(1 * time.Second)
|
|
fmt.Println(callCount)
|
|
|
|
debouncedFn()
|
|
|
|
time.Sleep(1 * time.Second)
|
|
fmt.Println(callCount)
|
|
|
|
// Output:
|
|
// 1
|
|
// 2
|
|
}
|
|
|
|
func ExampleDebounced() {
|
|
count := 0
|
|
add := func() {
|
|
count++
|
|
}
|
|
|
|
debouncedAdd := Debounced(add, 50*time.Microsecond)
|
|
|
|
debouncedAdd()
|
|
debouncedAdd()
|
|
debouncedAdd()
|
|
debouncedAdd()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
|
|
fmt.Println(count)
|
|
|
|
debouncedAdd()
|
|
|
|
time.Sleep(100 * time.Millisecond)
|
|
|
|
fmt.Println(count)
|
|
|
|
// Output:
|
|
// 1
|
|
// 2
|
|
}
|
|
|
|
func ExampleSchedule() {
|
|
count := 0
|
|
|
|
increase := func() {
|
|
count++
|
|
}
|
|
|
|
stop := Schedule(2*time.Second, increase)
|
|
|
|
time.Sleep(2 * time.Second)
|
|
close(stop)
|
|
|
|
fmt.Println(count)
|
|
|
|
// Output:
|
|
// 2
|
|
}
|
|
|
|
func ExamplePipeline() {
|
|
addOne := func(x int) int {
|
|
return x + 1
|
|
}
|
|
double := func(x int) int {
|
|
return 2 * x
|
|
}
|
|
square := func(x int) int {
|
|
return x * x
|
|
}
|
|
|
|
fn := Pipeline(addOne, double, square)
|
|
|
|
result := fn(2)
|
|
|
|
fmt.Println(result)
|
|
|
|
// Output:
|
|
// 36
|
|
}
|
|
|
|
func ExampleAcceptIf() {
|
|
|
|
adder := AcceptIf(
|
|
And(
|
|
func(x int) bool {
|
|
return x > 10
|
|
}, func(x int) bool {
|
|
return x%2 == 0
|
|
}),
|
|
func(x int) int {
|
|
return x + 1
|
|
},
|
|
)
|
|
|
|
result, ok := adder(20)
|
|
fmt.Println(result)
|
|
fmt.Println(ok)
|
|
|
|
result, ok = adder(21)
|
|
fmt.Println(result)
|
|
fmt.Println(ok)
|
|
|
|
// Output:
|
|
// 21
|
|
// true
|
|
// 0
|
|
// false
|
|
}
|
|
|
|
func ExampleThrottle() {
|
|
callCount := 0
|
|
|
|
fn := func() {
|
|
callCount++
|
|
}
|
|
|
|
throttledFn := Throttle(fn, 1*time.Second)
|
|
|
|
for i := 0; i < 5; i++ {
|
|
throttledFn()
|
|
}
|
|
|
|
time.Sleep(1 * time.Second)
|
|
|
|
fmt.Println(callCount)
|
|
|
|
// Output:
|
|
// 1
|
|
}
|