@effector/canary
Advanced tools
Reactive state manager
Effector is an effective multi-store state manager for Javascript apps (React/React Native/Vue/Node.js), that allows you to manage data in complex applications without the risk of inflating the monolithic central store, with clear control flow, good type support and high capacity API. Effector supports both TypeScript and Flow type annotations out of the box.
npm install --save effector
# or
yarn add effector
React
npm install --save effector effector-react
# or
yarn add effector effector-react
Vue
npm install --save effector effector-vue
# or
yarn add effector effector-vue
CDN
| Package | Version | Dependencies | Size |
|---|---|---|---|
effector |  |  |  |
effector-react |  |  |  |
effector-vue |  |  |  |
| Package | Version | Dependencies |
|---|---|---|
@effector/babel-plugin |  |  |
@effector/babel-plugin-react |  |  |
| Package | Version | Dependencies |
|---|---|---|
bs-effector |  |  |
bs-effector-react |  |  |
You can try effector in our repl
Code sharing, Typescript and react supported out of the box; and of course, it built with effector
import {createStore, createEvent} from 'effector'
import {useStore} from 'effector-react'
const increment = createEvent('increment')
const decrement = createEvent('decrement')
const resetCounter = createEvent('reset counter')
const counter = createStore(0)
.on(increment, state => state + 1)
.on(decrement, state => state - 1)
.reset(resetCounter)
counter.watch(console.log)
const Counter = () => {
const value = useStore(counter)
return <div>{value}</div>
}
const App = () => {
const value = useStore(counter)
return (
<>
<Counter />
<button onClick={increment}>+</button>
<button onClick={decrement}>-</button>
<button onClick={resetCounter}>reset</button>
</>
)
}
const {createEvent} = require('effector')
const messageEvent = createEvent()
messageEvent.watch(text => console.log(`new message: ${text}`))
messageEvent('hello world')
// => new message: hello world
const {createStore, createEvent} = require('effector')
const turnOn = createEvent()
const turnOff = createEvent()
const status = createStore('offline')
.on(turnOn, () => 'online')
.on(turnOff, () => 'offline')
status.watch(newStatus => {
console.log(`status changed: ${newStatus}`)
})
// for store watchs callback invokes immediately
// "status changed: offline"
turnOff() // nothing has changed, callback is not triggered
turnOn() // "status changed: online"
turnOff() // "status changed: offline"
turnOff() // nothing has changed
useList hookguardEvent is an intention to change state.
import {createEvent} from 'effector'
const send = createEvent() // unnamed event
const onMessage = createEvent('message') // named event
const socket = new WebSocket('wss://echo.websocket.org')
socket.onmessage = msg => onMessage(msg)
socket.onopen = () => send('{"text": "hello"}')
const onMessageParse = onMessage.map(msg => JSON.parse(msg.data))
onMessageParse.watch(data => {
console.log('Message from server ', data)
})
send.watch(data => {
socket.send(data)
})
Effect is a container for async function. It can be safely used in place of the original async function.
import {createEffect} from 'effector'
const fetchUserRepos = createEffect({
async handler({name}) {
const url = `https://api.github.com/users/${name}/repos`
const req = await fetch(url)
return req.json()
},
})
// subscribe to pending store status
fetchUserRepos.pending.watch(pending => {
console.log(pending) // false
})
// subscribe to handler resolve
fetchUserRepos.done.watch(({params, result}) => {
console.log(params) // {name: 'zerobias'}
console.log(result) // resolved value
})
// subscribe to handler reject or throw error
fetchUserRepos.fail.watch(({params, error}) => {
console.error(params) // {name: 'zerobias'}
console.error(error) // rejected value
})
// subscribe to both cases
fetchUserRepos.finally.watch(data => {
if (data.status === 'done') {
const {params, result} = data
console.log(params) // {name: 'zerobias'}
console.log(result) // resolved value
} else {
const {params, error} = data
console.error(params) // {name: 'zerobias'}
console.error(error) // rejected value
}
})
// you can replace handler anytime
fetchUserRepos.use(requestMock)
// calling effect will return a promise
const result = await fetchUserRepos({name: 'zerobias'})
Store is an object that holds the state tree. There can be multiple stores.
// `getUsers` - is an effect
// `addUser` - is an event
const users = createStore([{ name: Joe }])
// subscribe store reducers to events
.on(getUsers.done, (oldState, payload) => payload)
.on(addUser, (oldState, payload) => [...oldState, payload]))
// subscribe to store updates
users.watch(state => console.log(state)) // `.watch` for a store is triggered immediately: `[{ name: Joe }]`
// `callback` will be triggered each time when `.on` handler returns the new state
Most profit thing of stores.
Get smaller part of the store:
// `.map` accept state of parent store and return new memoized store. No more reselect ;)
const firstUser = users.map(list => list[0])
firstUser.watch(newState => console.log(`first user name: ${newState.name}`)) // "first user name: Joe"
addUser({name: Joseph}) // `firstUser` is not updated
getUsers() // after promise resolve `firstUser` is updated and call all watchers (subscribers)
Compose stores:
import {createStore, combine} from 'effector'
const a = createStore(1)
const b = createStore('b')
const c = combine({a, b})
c.watch(console.log)
// => {a: 1, b: "b"}
See combine in docs
Domain is a namespace for your events, stores and effects. Domain can subscribe to event, effect, store or nested domain creation with onCreateEvent, onCreateStore, onCreateEffect, onCreateDomain(to handle nested domains) methods.
import {createDomain} from 'effector'
const mainPage = createDomain('main page')
mainPage.onCreateEvent(event => {
console.log('new event: ', event.getType())
})
mainPage.onCreateStore(store => {
console.log('new store: ', store.getState())
})
const mount = mainPage.createEvent('mount')
// => new event: main page/mount
const pageStore = mainPage.createStore(0)
// => new store: 0
See Domain in docs
See also worker-rpc example, which uses shared domain for effects
 Dmitry 💬 💻 📖 💡 🤔 🚇 ⚠️ |  andretshurotshka 💬 💻 📖 📦 ⚠️ |  Sergey Sova 📖 💡 |  Arutyunyan Artyom 📖 💡 |  Ilya 📖 |  Arthur Irgashev 📖 💻 💡 |  Igor Ryzhov 📖 |
 Egor Guscha 📖 |  bakugod 📖 💡 |  Ruslan 📖 💻 🤔 ⚠️ |  Maxim Alyoshin 📖 |  Andrey Gopienko 📖 |  Vadim Ivanov 📖 |  Aleksandr Anokhin 💻 |
 Anton Kosykh 💻 |  Konstantin Lebedev 💡 |  Pavel Tereschenko 💻 |  Satya Rohith 📖 |  Vladislav Melnikov 💻 |  Grigory Zaripov 💻 |  Marina Miyaoka 💻 |
 Evgeny Zakharov 📖 |  Viktor 💻 📖 ⚠️ 🤔 |  Ivan Savichev 💻 🤔 |  Nikita Nafranets 📖 💡 |  Tauyekel Kunzhol 📖 |  Andrew Laiff 📖 |  Illia Osmanov 💻 🤔 |
FAQs
The state manager
We found that @effector/canary demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 2 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
RubyGems.org has added a new "maintainer" role that allows for publishing new versions of gems. This new permission type is aimed at improving security for gem owners and the service overall.
Security News
Node.js will be enforcing stricter semver-major PR policies a month before major releases to enhance stability and ensure reliable release candidates.
Security News
Research
Socket's threat research team has detected five malicious npm packages targeting Roblox developers, deploying malware to steal credentials and personal data.